search

pystorm / streamparse

Run Python in Apache Storm topologies. Pythonic API, CLI tooling, and a topology DSL.
http://streamparse.readthedocs.io/
Apache License 2.0
1.5k stars 218 forks source link

streamparse wordcount demo not working with storm 1.1.2 #438

Open maynewong opened 6 years ago

maynewong commented 6 years ago

when i use "sparse run" command with storm version 1.1.2 the error show below:

4016 [main] ERROR o.a.s.d.nimbus - Error on initialization of server service-handler
java.lang.NullPointerException: null
        at org.apache.storm.nimbus.NimbusInfo.fromConf(NimbusInfo.java:56) ~[storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.daemon.nimbus$nimbus_data.invoke(nimbus.clj:186) ~[storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.daemon.nimbus$fn__11008$exec_fn__1370__auto____11009.invoke(nimbus.clj:2451) ~[storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.AFn.applyToHelper(AFn.java:156) ~[clojure-1.7.0.jar:?]
        at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.7.0.jar:?]
        at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.nimbus$fn__11008$service_handler__11041.doInvoke(nimbus.clj:2448) [storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.7.0.jar:?]
        at org.apache.storm.testing$mk_local_storm_cluster.doInvoke(testing.clj:156) [storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.7.0.jar:?]
        at org.apache.storm.LocalCluster$_init.invoke(LocalCluster.clj:31) [storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.LocalCluster.<init>(Unknown Source) [storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.flux.Flux.runCli(Flux.java:205) [wordcount-0.0.1-SNAPSHOT-standalone.jar:?]
        at org.apache.storm.flux.Flux.main(Flux.java:98) [wordcount-0.0.1-SNAPSHOT-standalone.jar:?]
4023 [main] ERROR o.a.s.util - Halting process: ("Error on initialization")
java.lang.RuntimeException: ("Error on initialization")
        at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.nimbus$fn__11008$service_handler__11041.doInvoke(nimbus.clj:2448) [storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.7.0.jar:?]
        at org.apache.storm.testing$mk_local_storm_cluster.doInvoke(testing.clj:156) [storm-core-1.1.2.jar:1.1.2]
        at clojure.lang.RestFn.invoke(RestFn.java:421) [clojure-1.7.0.jar:?]
        at org.apache.storm.LocalCluster$_init.invoke(LocalCluster.clj:31) [storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.LocalCluster.<init>(Unknown Source) [storm-core-1.1.2.jar:1.1.2]
        at org.apache.storm.flux.Flux.runCli(Flux.java:205) [wordcount-0.0.1-SNAPSHOT-standalone.jar:?]
        at org.apache.storm.flux.Flux.main(Flux.java:98) [wordcount-0.0.1-SNAPSHOT-standalone.jar:?]

Fatal error: local() encountered an error (return code 13) while executing 'storm jar /root/wordcount/_build/wordcount-0.0.1-SNAPSHOT-standalone.jar org.apache.storm.flux.Flux --local --no-splash --sleep 9223372036854775807 /tmp/tmpnwg_fs9t.yaml'

Aborting.

I changed 1.1.0 to 1.1.2 in project.clj file