Wrodcount example not work in local mode with storm 2.2.x version.
JeongtaekLim opened this issue · 2 comments
JeongtaekLim commented
I just want to report this bug(?) to somebody try to run wordcount
tutorial.
With storm version 2.2.x, there is little bit difference in storm
shell command between 2.2.x
and 1.2.3
So, sparse run
never run in local mode but run in deployment mode.
I'm new to storm, and spent 1 days for catching it..
wkvolkman commented
And in case someone runs across this
diff --git a/streamparse/cli/run.py b/streamparse/cli/run.py
index 776ef00..a0deb1b 100644
--- a/streamparse/cli/run.py
+++ b/streamparse/cli/run.py
@@ -85,7 +85,7 @@ def run_local_topology(
yml.default_flow_style = False
yml.dump(topology_flux_dict, yaml_file)
cmd = (
- "storm jar {jar} org.apache.storm.flux.Flux --local --no-splash "
+ "storm local {jar} org.apache.storm.flux.Flux --no-splash "
"--sleep {time} {yaml}".format(
jar=topology_jar, time=time, yaml=yaml_file.name
)