You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Rick Kellogg (JIRA)" <ji...@apache.org> on 2015/09/26 04:47:04 UTC
[jira] [Updated] (STORM-374) storm0.9.1&kafka0.8.1 with
storm-kafka-0.8-plus-0.5.0 can not run
[ https://issues.apache.org/jira/browse/STORM-374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rick Kellogg updated STORM-374:
-------------------------------
Component/s: storm-kafka
> 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
> Issue Type: Bug
> Components: storm-kafka
> 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.3.4#6332)