storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Viktor Pishchulin <vikt...@gmail.com>
Subject Re: Exception java.lang.NoSuchMethodError
Date Tue, 06 Sep 2016 13:41:19 GMT
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 <thomascristanis@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

Mime
View raw message