You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/12/20 08:57:04 UTC
[2/8] storm git commit: addressed review comments
addressed review comments
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/80210385
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/80210385
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/80210385
Branch: refs/heads/master
Commit: 802103857dfc212a79f495ad9ec18cd8fc538dc7
Parents: 9400ac5
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Fri Dec 2 15:29:38 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Dec 7 17:16:48 2016 -0600
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/starter/WordCountTopology.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/80210385/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java
index fef1594..c244fa1 100644
--- a/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java
+++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java
@@ -91,9 +91,7 @@ public class WordCountTopology {
if (args != null && args.length > 0) {
conf.setNumWorkers(3);
- for (String name: args) {
- StormSubmitter.submitTopologyWithProgressBar(name, conf, builder.createTopology());
- }
+ StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology());
}
else {
conf.setMaxTaskParallelism(3);