storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [3/5] storm git commit: - 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
Date Mon, 13 Jul 2015 14:00:51 GMT
- 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.psg@gmail.com>
Authored: Fri Jul 3 10:44:07 2015 -0500
Committer: Shyam Rajendran <rshyam.psg@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()) {


Mime
View raw message