You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Thomas Cristanis <th...@gmail.com> on 2016/09/06 12:45:53 UTC
Exception java.lang.NoSuchMethodError
I'm getting this error when running a topology that uses a KafkaSpout.
Is anyone having this problem?
You have no idea what can be?
31455 [Thread-66-kafka-spout-executor[21 21]] INFO
o.a.s.k.PartitionManager - Read partition information from:
/teste/35f1a742-784e-4a0a-9222-d7621aa8884b/partition_0 --> null
log4j:WARN No appenders could be found for logger
(kafka.consumer.SimpleConsumer).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
31540 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Async loop
died!
java.lang.NoSuchMethodError:
org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V
at
kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.network.BlockingChannel.send(BlockingChannel.scala:112)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:83)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
~[kafka_2.11-0.10.0.0.jar:?]
at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:103)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(
ZkCoordinator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129)
~[storm-kafka-1.0.2.jar:1.0.2]
at
org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
[storm-core-1.0.2.jar:1.0.2]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
31549 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.d.executor -
java.lang.NoSuchMethodError:
org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V
at
kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.network.BlockingChannel.send(BlockingChannel.scala:112)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:83)
~[kafka_2.11-0.10.0.0.jar:?]
at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149)
~[kafka_2.11-0.10.0.0.jar:?]
at
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
~[kafka_2.11-0.10.0.0.jar:?]
at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:103)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(
ZkCoordinator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2]
at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129)
~[storm-kafka-1.0.2.jar:1.0.2]
at
org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
[storm-core-1.0.2.jar:1.0.2]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
31614 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Halting
process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341)
[storm-core-1.0.2.jar:1.0.2]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
at org.apache.storm.daemon.worker$fn__8659$fn__8660.invoke(worker.clj:761)
[storm-core-1.0.2.jar:1.0.2]
at
org.apache.storm.daemon.executor$mk_executor_data$fn__7875$fn__7876.invoke(executor.clj:274)
[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:494)
[storm-core-1.0.2.jar:1.0.2]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
Re: Exception java.lang.NoSuchMethodError
Posted by Viktor Pishchulin <vi...@gmail.com>.
Hi Thomas,
org.apache.kafka.common.network.NetworkSend - is class from Kafka client
library. Before Kafka 0.9, constructor for that class had "int" as first
argument. Are you sure that you have only one version of kafka-client jar
in your classpath?
Regards,
Viktor
On 6 September 2016 at 05:45, Thomas Cristanis <th...@gmail.com>
wrote:
> I'm getting this error when running a topology that uses a KafkaSpout.
> Is anyone having this problem?
> You have no idea what can be?
>
> 31455 [Thread-66-kafka-spout-executor[21 21]] INFO
> o.a.s.k.PartitionManager - Read partition information from:
> /teste/35f1a742-784e-4a0a-9222-d7621aa8884b/partition_0 --> null
>
> log4j:WARN No appenders could be found for logger (kafka.consumer.
> SimpleConsumer).
>
> log4j:WARN Please initialize the log4j system properly.
>
> log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
> more info.
>
> 31540 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Async
> loop died!
>
> java.lang.NoSuchMethodError: org.apache.kafka.common.
> network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V
>
> at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:112)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$
> $sendRequest(SimpleConsumer.scala:83) ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.PartitionManager.<init>(Partit
> ionManager.java:103) ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoord
> inator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
> ~[storm-core-1.0.2.jar:1.0.2]
>
> at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
> [storm-core-1.0.2.jar:1.0.2]
>
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
>
> 31549 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.d.executor -
>
> java.lang.NoSuchMethodError: org.apache.kafka.common.
> network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V
>
> at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.network.BlockingChannel.send(BlockingChannel.scala:112)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$
> $sendRequest(SimpleConsumer.scala:83) ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
> ~[kafka_2.11-0.10.0.0.jar:?]
>
> at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.PartitionManager.<init>(Partit
> ionManager.java:103) ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoord
> inator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129)
> ~[storm-kafka-1.0.2.jar:1.0.2]
>
> at org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
> ~[storm-core-1.0.2.jar:1.0.2]
>
> at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
> [storm-core-1.0.2.jar:1.0.2]
>
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
>
> 31614 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Halting
> process: ("Worker died")
>
> java.lang.RuntimeException: ("Worker died")
>
> at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341)
> [storm-core-1.0.2.jar:1.0.2]
>
> at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
>
> at org.apache.storm.daemon.worker$fn__8659$fn__8660.invoke(worker.clj:761)
> [storm-core-1.0.2.jar:1.0.2]
>
> at org.apache.storm.daemon.executor$mk_executor_data$fn__
> 7875$fn__7876.invoke(executor.clj:274) [storm-core-1.0.2.jar:1.0.2]
>
> at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:494)
> [storm-core-1.0.2.jar:1.0.2]
>
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
>
--
With best regards,
Viktor M. Pishchulin