pystorm/streamparse

Wrodcount example not work in local mode with storm 2.2.x version.

JeongtaekLim opened this issue · 2 comments

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..

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
                 )