- Fix for imports missing - Tested on local machine ( mac ) with changes to WordCountTopologyNode.java and WordCountTopology.java by setting the environment variable for Spout and Bolt. - Unwanted debug removed
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2d27c64c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2d27c64c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2d27c64c Branch: refs/heads/master Commit: 2d27c64c433fc3178651d318dbc409c086f9fd6d Parents: 87772f2 Author: Shyam Rajendran <rshyam....@gmail.com> Authored: Fri Jul 3 10:44:07 2015 -0500 Committer: Shyam Rajendran <rshyam....@gmail.com> Committed: Sun Jul 5 10:30:58 2015 -0500 ---------------------------------------------------------------------- storm-core/src/jvm/backtype/storm/spout/ShellSpout.java | 1 + storm-core/src/jvm/backtype/storm/utils/ShellProcess.java | 2 ++ 2 files changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2d27c64c/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java index 91e2629..a69b9b2 100644 --- a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java +++ b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java @@ -26,6 +26,7 @@ import backtype.storm.multilang.SpoutMsg; import backtype.storm.task.TopologyContext; import backtype.storm.utils.ShellProcess; import java.util.Map; +import java.util.HashMap; import java.util.List; import java.util.TimerTask; import java.util.concurrent.ScheduledExecutorService; http://git-wip-us.apache.org/repos/asf/storm/blob/2d27c64c/storm-core/src/jvm/backtype/storm/utils/ShellProcess.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/utils/ShellProcess.java b/storm-core/src/jvm/backtype/storm/utils/ShellProcess.java index 300bf57..d1b2800 100644 --- a/storm-core/src/jvm/backtype/storm/utils/ShellProcess.java +++ b/storm-core/src/jvm/backtype/storm/utils/ShellProcess.java @@ -28,6 +28,7 @@ import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.Serializable; +import java.util.HashMap; import java.util.List; import java.util.Map; @@ -63,6 +64,7 @@ public class ShellProcess implements Serializable { } } + public Number launch(Map conf, TopologyContext context) { ProcessBuilder builder = new ProcessBuilder(command); if (!env.isEmpty()) {
