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.49k stars 217 forks source link

Fatal error: local() encountered an error (return code 1) while executing 'storm jar /path_to_project/_build/try-0.0.1-kafka-standalone.jar org.apache.storm.flux.Flux --local --no-splash --sleep 9223372036854775807 #430

Open shahidammer opened 6 years ago

shahidammer commented 6 years ago

I am trying to implement storm in python using streamparse. Basically i have a kafka cluster and i am trying to get data from the broker and perform some processing but i am stuck with an error which says

Fatal error: local() encountered an error (return code 1) while executing 'storm jar /Users/shahidammer/.gvm/pkgsets/go1.9.2/global/src/devden/try/_build/try-0.0.1-kafka-standalone.jar org.apache.storm.flux.Flux --local --no-splash --sleep 9223372036854775807 /var/folders/2c/z561kl756y9gwhmrhvwgr43c0000gq/T/tmpAd5Ck5.yaml'

Here is my project.clij file

(defproject try "0.0.1-kafka" :resource-paths ["_resources"] :target-path "_build" :min-lein-version "2.0.0" :jvm-opts ["-client"] :dependencies [[org.apache.storm/storm-core "1.2.1"] [org.apache.storm/flux-core "1.2.1"] [org.apache.storm/storm-kafka "0.9.4" ] [org.apache.kafka/kafka_2.9.2 "0.8.1.1" ] [org.apache.zookeeper/zookeeper "3.4.6" ]] :jar-exclusions [#"log4j\.properties" #"org\.apache\.storm\.(?!flux)" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] :uberjar-exclusions [#"log4j\.properties" #"org\.apache\.storm\.(?!flux)" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] )

I have storm installed locally but all the other packages like zookeeper, kafka etc is not installed. Am I suppose to install it on my localhost?

Do i need to change my project.cli file?

cwwong1606 commented 5 years ago

I also encounter the same problem as described. Can anyone help?