您现在的位置是:首页 >其他 >flume与hadoop jar包冲突网站首页其他

flume与hadoop jar包冲突

MJK祺 2024-06-17 10:26:03
简介flume与hadoop jar包冲突

在运行flume时报了以下错误:

2023-05-14 20:45:44,445 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR - org.apache.  flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:459)] process failed
java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V
        at org.apache.hadoop.conf.Configuration.set(Configuration.java:1357)
        at org.apache.hadoop.conf.Configuration.set(Configuration.java:1338)
        at org.apache.hadoop.conf.Configuration.setBoolean(Configuration.java:1679)
        at org.apache.flume.sink.hdfs.BucketWriter.open(BucketWriter.java:221)
        at org.apache.flume.sink.hdfs.BucketWriter.append(BucketWriter.java:572)
        at org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:412)
        at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
        at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
        at java.lang.Thread.run(Thread.java:748)
Exception in thread "SinkRunner-PollingRunner-DefaultSinkProcessor" java.lang.NoSuchMethodError:com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V
        at org.apache.hadoop.conf.Configuration.set(Configuration.java:1357)
        at org.apache.hadoop.conf.Configuration.set(Configuration.java:1338)
        at org.apache.hadoop.conf.Configuration.setBoolean(Configuration.java:1679)
        at org.apache.flume.sink.hdfs.BucketWriter.open(BucketWriter.java:221)
        at org.apache.flume.sink.hdfs.BucketWriter.append(BucketWriter.java:572)
        at org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:412)
        at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
        at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
        at java.lang.Thread.run(Thread.java:748)

原因: flume和hadoop的guava包冲突

(flume的版本是guava-11.0.2.jar,hadoop的是guava-27.0-jre.jar)

解决办法:将hadoop的guava包替换掉flume的低版本包即可

(hadoop的guava包在$HADOOP_HOME/share/hadoop/common/lib/)

cp /opt/servers/hadoop/share/hadoop/common/lib/guava-27.0-jre.jar /opt/servers/flume/lib/

rm -rf /opt/servers/flume/lib/guava-11.0.2.jar

然后再运行就不会报错了

风语者!平时喜欢研究各种技术,目前在从事后端开发工作,热爱生活、热爱工作。