note: I use storm 0.9.4, and tried the trunk for 0.9.6 and still have the problem
________________________________ De : Eric Ruel Envoyé : 22 juillet 2015 10:43 À : [email protected] Objet : worker dies after view minutes Hello the workers in my topology dies after 1,2 minutes I tried to change the config about the heartbeat, cluster or local mode, but they always die any idea? 10:38:38.019 ERROR backtype.storm.daemon.worker - Error when processing event java.lang.RuntimeException: org.apache.storm.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /workerbeats/testeric-1-1437575782/259f61ae-02a5-4a75-be50-68f27054a7b2-1024 at backtype.storm.util$wrap_in_runtime.invoke(util.clj:44) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.zookeeper$set_data.invoke(zookeeper.clj:173) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.cluster$mk_distributed_cluster_state$reify__1919.set_data(cluster.clj:92) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.cluster$mk_storm_cluster_state$reify__2376.worker_heartbeat_BANG_(cluster.clj:332) ~[storm-core-0.9.6.jar:0.9.6] at sun.reflect.GeneratedMethodAccessor135.invoke(Unknown Source) ~[na:na] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_71] at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_71] at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) ~[clojure-1.5.1.jar:na] at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$do_executor_heartbeats.doInvoke(worker.clj:56) ~[storm-core-0.9.6.jar:0.9.6] at clojure.lang.RestFn.invoke(RestFn.java:439) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$fn__3757$exec_fn__1163__auto____3758$fn__3761.invoke(worker.clj:413) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.timer$schedule_recurring$this__1704.invoke(timer.clj:99) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.timer$mk_timer$fn__1687$fn__1688.invoke(timer.clj:50) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.timer$mk_timer$fn__1687.invoke(timer.clj:42) [storm-core-0.9.6.jar:0.9.6] 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_71] Caused by: org.apache.storm.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /workerbeats/testeric-1-1437575782/259f61ae-02a5-4a75-be50-68f27054a7b2-1024 at org.apache.storm.zookeeper.KeeperException.create(KeeperException.java:99) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.zookeeper.KeeperException.create(KeeperException.java:51) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.zookeeper.ZooKeeper.setData(ZooKeeper.java:1270) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.framework.imps.SetDataBuilderImpl$4.call(SetDataBuilderImpl.java:260) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.framework.imps.SetDataBuilderImpl$4.call(SetDataBuilderImpl.java:256) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.RetryLoop.callWithRetry(RetryLoop.java:107) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.framework.imps.SetDataBuilderImpl.pathInForeground(SetDataBuilderImpl.java:252) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.framework.imps.SetDataBuilderImpl.forPath(SetDataBuilderImpl.java:239) ~[storm-core-0.9.6.jar:0.9.6] at org.apache.storm.curator.framework.imps.SetDataBuilderImpl.forPath(SetDataBuilderImpl.java:39) ~[storm-core-0.9.6.jar:0.9.6] at backtype.storm.zookeeper$set_data.invoke(zookeeper.clj:172) ~[storm-core-0.9.6.jar:0.9.6] ... 15 common frames omitted 10:38:38.023 ERROR backtype.storm.util - Halting process: ("Error when processing an event") java.lang.RuntimeException: ("Error when processing an event") at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:325) [storm-core-0.9.6.jar:0.9.6] at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$mk_halting_timer$fn__3572.invoke(worker.clj:177) [storm-core-0.9.6.jar:0.9.6] at backtype.storm.timer$mk_timer$fn__1687$fn__1688.invoke(timer.clj:68) [storm-core-0.9.6.jar:0.9.6] at backtype.storm.timer$mk_timer$fn__1687.invoke(timer.clj:42) [storm-core-0.9.6.jar:0.9.6] 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_71]
