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

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

Closed JeongtaekLim closed 2 months ago

JeongtaekLim commented 4 years ago

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 3 years ago

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
                 )
kbourgoin commented 2 months ago

Cleaning out old issues. Please reopen if this is still an issue.