Kafka下沉到HDFS报错

news/2024/5/20 2:31:39 标签: kafka, hdfs

错误信息

24 十二月 2023 12:38:25,127 INFO [SinkRunner-PollingRunner-DefaultSinkProcessor] (org.apache.flume.sink.hdfs.HDFSCompressedDataStream.configure:64) - Serializer = TEXT, UseRawLocalFileSystem = false
24 十二月 2023 12:38:25,129 ERROR [SinkRunner-PollingRunner-DefaultSinkProcessor] (org.apache.flume.sink.hdfs.HDFSEventSink.process:457) - process failed
java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V

错误原因

由于hadoop和flume中guava这个jar包冲突导致，二者不兼容。

解决办法

把flume中的guava包删掉，即可正常运行。

http://www.niftyadmin.cn/n/5285054.html

vue 父页面监听子页面值的变化

在Vue中，可以通过使用$emit()来触发事件并传递数据。首先，需要在父组件中定义一个自定义事件名称，然后将该事件与相应的处理函数关联起来。当子组件改变了其值时，就会调用这个处理函数。下面是一个示例代码： <…

二叉树的递归遍历|前中后序遍历、最大深度、最大直径

二叉树的递归遍历前序遍历 public List<Integer> preorderTraversal(TreeNode root) {List<Integer> res new ArrayList<>();if (root null) {return res;}res.add(root.val);if (root.left ! null) {res.addAll(preorderTraversal(root.left));}if (roo…

新版IDEA中Git的使用（三）

说明：前面介绍了在新版IDEA中Git的基本操作、分支操作，本文介绍一下在新版IDEA中，如何回滚代码； 分以下三个阶段来介绍： 未Commit的文件； 已经Commit，但未Push的文件； 已经Push的…

关于Python里xlwings库对Excel表格的操作（十七）

这篇小笔记主要记录如何【获取和设置单元格行高、列宽】。前面的小笔记已整理成目录，可点链接去目录寻找所需更方便。【目录部分内容如下】【点击此处可进入目录】 （1）如何安装导入xlwings库； （2）如何在W…

Python画皮卡丘

代码： import turtledef getPosition(x, y):turtle.setx(x)turtle.sety(y)print(x, y)class Pikachu:def __init__(self):self.t turtle.Turtle()t self.tt.pensize(3)t.speed(9)t.ondrag(getPosition)def noTrace_goto(self, x, y):self.t.penup()self.t.goto(…

计算机组成原理第6章-（算术运算）【下】

移位运算对于有符号数的移位称为算术移位，对于无符号数的移位称为逻辑移位。算术移位规则【极其重要】对于正数的算术移位，且不管是何种机器数【原码、反码、补码】，移位后出现的空位全部填0。而对于负数的算术移位，机器数不同，移位后的规则也不同。对于负数的原…

CentOS+ISCSI

九、配置iSCSI 添加1块大小为10G的虚拟硬盘；安装iSCSI服务端targetcli；使用新增加的硬盘创建卷组，名称为iscsivg，再创建iSCSI共享逻辑卷，逻辑卷名称为iscsistore，大小为5G；使用上述逻辑卷创建后端存储，名称为serverc.iscsistore；定义iSCSI的IQN为iqn.2022-…

19、Qt线程（四）：继承QRunnable类

一、功能说明 1、通过继承QRunnable，重写run的方式实现多线程 2、点击“开始”按钮启动子线程； 二、项目创建 1、新建Qt Widgets Application应用，名称为Runnable，基类选择QMainWindow； 2、MainWindow.ui中放入一…