Thanks, that worked! But nothing is moving around in the topology! No errors in the logs except for log4j multiple bindings.
Topology logs: 2015-06-19 14:01:42.824 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm7.whizdm.com/172.31.14.215:6701 2015-06-19 14:01:42.824 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm3.whizdm.com/172.31.15.94:6701 2015-06-19 14:01:42.824 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm2.whizdm.com/172.31.7.162:6701 2015-06-19 14:01:42.824 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm1.whizdm.com/172.31.2.109:6701 2015-06-19 14:01:42.824 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm8.whizdm.com/172.31.15.65:6701 2015-06-19 14:01:42.825 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm6.whizdm.com/172.31.14.214:6701 2015-06-19 14:01:42.825 b.s.m.n.Client [INFO] Getting metrics for client connection to Netty-Client-storm4.whizdm.com/172.31.6.82:6701 Has something changed in the way spouts are implemented? On Thu, Jun 18, 2015 at 6:15 PM, Parth Brahmbhatt < [email protected]> wrote: > You need to delete all data under /storm in zookeeper. In addition you > will also need to delete all data under storm-local directory from nimbus > and supervisor nodes. This means you lost all your topologies so you will > have to resubmit the topologies once you restart the cluster. > > > > On Jun 18, 2015, at 12:33 PM, bhargav sarvepalli <[email protected]> > wrote: > > Hi, > > We are trying to use Storm 0.10.0 beta version. When we try to start > nimbus we get the following error. Please suggest ways to get rid of it :) > > Stacktrace: > > > ERROR backtype.storm.daemon.nimbus - Error on initialization of server > service-handler > > java.lang.RuntimeException: java.lang.RuntimeException: > java.util.zip.ZipException: Not in GZIP format > > at > backtype.storm.serialization.GzipThriftSerializationDelegate.deserialize(GzipThriftSerializationDelegate.java:54) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.utils.Utils.deserialize(Utils.java:80) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.cluster$maybe_deserialize.invoke(cluster.clj:246) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at > backtype.storm.cluster$mk_storm_cluster_state$reify__3114.storm_base(cluster.clj:426) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > ~[na:1.7.0_75] > > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) > ~[na:1.7.0_75] > > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > ~[na:1.7.0_75] > > at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_75] > > at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) > ~[clojure-1.6.0.jar:na] > > at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) > ~[clojure-1.6.0.jar:na] > > at backtype.storm.daemon.nimbus$transition_BANG_.invoke(nimbus.clj:205) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.daemon.nimbus$transition_BANG_.invoke(nimbus.clj:200) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at > backtype.storm.daemon.nimbus$fn__3804$exec_fn__1233__auto____3805.invoke(nimbus.clj:1018) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.AFn.applyToHelper(AFn.java:156) [clojure-1.6.0.jar:na] > > at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:na] > > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:na] > > at > backtype.storm.daemon.nimbus$fn__3804$service_handler__3924.doInvoke(nimbus.clj:1010) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.6.0.jar:na] > > at > backtype.storm.daemon.nimbus$launch_server_BANG_.invoke(nimbus.clj:1367) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.daemon.nimbus$_launch.invoke(nimbus.clj:1398) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.daemon.nimbus$_main.invoke(nimbus.clj:1421) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.AFn.applyToHelper(AFn.java:152) [clojure-1.6.0.jar:na] > > at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:na] > > at backtype.storm.daemon.nimbus.main(Unknown Source) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > Caused by: java.lang.RuntimeException: java.util.zip.ZipException: Not in > GZIP format > > at backtype.storm.utils.Utils.gunzip(Utils.java:135) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > at > backtype.storm.serialization.GzipThriftSerializationDelegate.deserialize(GzipThriftSerializationDelegate.java:51) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > ... 23 common frames omitted > > Caused by: java.util.zip.ZipException: Not in GZIP format > > at java.util.zip.GZIPInputStream.readHeader(GZIPInputStream.java:164) > ~[na:1.7.0_75] > > at java.util.zip.GZIPInputStream.<init>(GZIPInputStream.java:78) > ~[na:1.7.0_75] > > at java.util.zip.GZIPInputStream.<init>(GZIPInputStream.java:90) > ~[na:1.7.0_75] > > at backtype.storm.utils.Utils.gunzip(Utils.java:125) > ~[storm-core-0.10.0-beta.jar:0.10.0-beta] > > ... 24 common frames omitted > > 11:32:35.049 [main] ERROR backtype.storm.util - Halting process: ("Error > on initialization") > > java.lang.RuntimeException: ("Error on initialization") > > at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:332) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:na] > > at > backtype.storm.daemon.nimbus$fn__3804$service_handler__3924.doInvoke(nimbus.clj:1010) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.6.0.jar:na] > > at > backtype.storm.daemon.nimbus$launch_server_BANG_.invoke(nimbus.clj:1367) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.daemon.nimbus$_launch.invoke(nimbus.clj:1398) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at backtype.storm.daemon.nimbus$_main.invoke(nimbus.clj:1421) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > > at clojure.lang.AFn.applyToHelper(AFn.java:152) [clojure-1.6.0.jar:na] > > at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:na] > > at backtype.storm.daemon.nimbus.main(Unknown Source) > [storm-core-0.10.0-beta.jar:0.10.0-beta] > >
