[
https://issues.apache.org/jira/browse/STORM-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yitao Jiang updated STORM-1194:
-------------------------------
Environment:
standalone local node storm
R
was:
standalone local node storm
> 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
> R
> 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)
