cha369 created STORM-374:
----------------------------
Summary: storm0.9.1&kafka0.8.1 with storm-kafka-0.8-plus-0.5.0 can
not run
Key: STORM-374
URL: https://issues.apache.org/jira/browse/STORM-374
Project: Apache Storm (Incubating)
Issue Type: Bug
Affects Versions: 0.9.1-incubating
Environment: centos5.4
java1.6.0_45
Reporter: cha369
Fix For: 0.9.1-incubating
ERROR backtype.storm.util - Async loop died!
java.lang.NoSuchMethodError:
com.netflix.curator.framework.api.CreateBuilder.creatingParentsIfNeeded()Lcom/netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable;
at storm.kafka.ZkState.writeBytes(ZkState.java:59)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.ZkState.writeJSON(ZkState.java:53)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.PartitionManager.commit(PartitionManager.java:188)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at
backtype.storm.daemon.executor$eval5100$fn__5101$fn__5116$fn__5145.invoke(executor.clj:562)
~[na:na]
at backtype.storm.util$async_loop$fn__390.invoke(util.clj:433) ~[na:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:662) [na:1.6.0_45]
12949 [Thread-27-words] ERROR backtype.storm.daemon.executor -
java.lang.NoSuchMethodError:
com.netflix.curator.framework.api.CreateBuilder.creatingParentsIfNeeded()Lcom/netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable;
at storm.kafka.ZkState.writeBytes(ZkState.java:59)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.ZkState.writeJSON(ZkState.java:53)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.PartitionManager.commit(PartitionManager.java:188)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134)
~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na]
at
backtype.storm.daemon.executor$eval5100$fn__5101$fn__5116$fn__5145.invoke(executor.clj:562)
~[na:na]
at backtype.storm.util$async_loop$fn__390.invoke(util.clj:433) ~[na:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:662) [na:1.6.0_45]
12971 [Thread-27-words] INFO backtype.storm.util - Halting process: ("Worker
died")
--
This message was sent by Atlassian JIRA
(v6.2#6252)
