Yitao Jiang created STORM-1194:
----------------------------------
Summary: java.lang.NoClassDefFoundError: Could not initialize
class org.apache.log4j.Log4jLoggerFactory
Key: STORM-1194
URL: https://issues.apache.org/jira/browse/STORM-1194
Project: Apache Storm
Issue Type: Question
Components: storm-core
Affects Versions: 0.9.5
Environment: standalone local node storm
Reporter: Yitao Jiang
can not consume topic from Kafka using storm-kafka, failed with
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.log4j.Log4jLoggerFactory
at org.apache.log4j.Logger.getLogger(Logger.java:39)
~[log4j-over-slf4j-1.6.6.jar:1.6.6]
at kafka.utils.Logging$class.logger(Logging.scala:24)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.network.BlockingChannel.logger$lzycompute(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.logger(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.utils.Logging$class.debug(Logging.scala:51)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.debug(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:64)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.getOrMakeConnection(SimpleConsumer.scala:142)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:69)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:124)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
~[kafka_2.10-0.8.1.1.jar:na]
at storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:77)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:67)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.PartitionManager.<init>(PartitionManager.java:83)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
~[storm-kafka-0.9.5.jar:0.9.5]
at
storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:135)
~[storm-kafka-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.executor$fn__3371$fn__3386$fn__3415.invoke(executor.clj:565)
~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80]
67167 [Thread-20-spout] ERROR backtype.storm.daemon.executor -
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.log4j.Log4jLoggerFactory
at org.apache.log4j.Logger.getLogger(Logger.java:39)
~[log4j-over-slf4j-1.6.6.jar:1.6.6]
at kafka.utils.Logging$class.logger(Logging.scala:24)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.network.BlockingChannel.logger$lzycompute(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.logger(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.utils.Logging$class.debug(Logging.scala:51)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.debug(BlockingChannel.scala:35)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:64)
~[kafka_2.10-0.8.1.1.jar:na]
at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.getOrMakeConnection(SimpleConsumer.scala:142)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:69)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:124)
~[kafka_2.10-0.8.1.1.jar:na]
at
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
~[kafka_2.10-0.8.1.1.jar:na]
at storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:77)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:67)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.PartitionManager.<init>(PartitionManager.java:83)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
~[storm-kafka-0.9.5.jar:0.9.5]
at
storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69)
~[storm-kafka-0.9.5.jar:0.9.5]
at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:135)
~[storm-kafka-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.executor$fn__3371$fn__3386$fn__3415.invoke(executor.clj:565)
~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80]
67235 [Thread-20-spout] ERROR backtype.storm.util - Halting process: ("Worker
died")
java.lang.RuntimeException: ("Worker died")
at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:325)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.worker$fn__4694$fn__4695.invoke(worker.clj:493)
[storm-core-0.9.5.jar:0.9.5]
at
backtype.storm.daemon.executor$mk_executor_data$fn__3272$fn__3273.invoke(executor.clj:240)
[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:473)
[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
