【发布时间】:2018-07-23 19:49:01
【问题描述】:
我正在使用storm:0.9.7,scala-library:2.11.7,kafka-clients:0.9.0.0,kafka:kafka_2.11
运行时错误:
java.lang.NoSuchMethodError: backtype.storm.spout.MultiScheme.deserialize([B)Ljava/lang/Iterable;
at storm.kafka.KafkaUtils.generateTuples(KafkaUtils.java:209) ~[stormjar.jar:0.3-SNAPSHOT]
at storm.kafka.PartitionManager.next(PartitionManager.java:131) ~[stormjar.jar:0.3-SNAPSHOT]
at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:141) ~[stormjar.jar:0.3-SNAPSHOT]
at com.aexp.fastdata.core.builder.spout.KafkaExtractorSpout.nextTuple(KafkaExtractorSpout.java:112) ~[stormjar.jar:0.3-SNAPSHOT]
at backtype.storm.daemon.executor$fn__4615$fn__4630$fn__4661.invoke(executor.clj:610) ~[storm-core-0.10.0-mapr-1611.jar:0.10.0-mapr-1611]
at backtype.storm.util$async_loop$fn__544.invoke(util.clj:479) [storm-core-0.10.0-mapr-1611.jar:0.10.0-mapr-1611]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141]
【问题讨论】:
-
您能否详细说明您的环境、您如何运行代码等?我认为可能存在过时或冲突的依赖关系的问题,或者您可能只是遗漏了一些东西。但我不能仅仅通过堆栈跟踪来排除任何这种情况