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

No module named streamparse.run ? #377

Closed BreakTom closed 7 years ago

BreakTom commented 7 years ago 
from streamparse.run import main

ImportError: No module named streamparse.run

at org.apache.storm.utils.ShellProcess.launch(ShellProcess.java:96) ~[storm-core-1.1.0.jar:1.1.0]
at org.apache.storm.task.ShellBolt.prepare(ShellBolt.java:150) ~[storm-core-1.1.0.jar:1.1.0]
at org.apache.storm.daemon.executor$fn__5044$fn__5057.invoke(executor.clj:791) ~[storm-core-1.1.0.jar:1.1.0]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:482) [storm-core-1.1.0.jar:1.1.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]

Fatal error: local() encountered an error (return code 1) while executing 'storm jar /Users/liu/wordcount/_build/wordcount-0.0.1-SNAPSHOT-standalone.jar org.apache.storm.flux.Flux --local --no-splash --sleep 9223372036854775807 /var/folders/rw/v_d8ch7148ldsjlny5dk7x640000gn/T/tmpk7JtbI.yaml'

Aborting.

why?

dan-blanchard commented 7 years ago

I need a lot more information to be helpful:

BreakTom commented 7 years ago

sorry,I have solved the problem, I pip install streamparse in virtualenv,I don't know what's wrong.environment variable?

dan-blanchard commented 7 years ago

If streamparse wasn't install in your virtualenv, that error would be expected.