You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2016/06/20 23:43:46 UTC
storm git commit: BUGFIX: HDFSFileTopology should use the 3rd ags as
topologyName.
Repository: storm
Updated Branches:
refs/heads/1.x-branch f9d561a7f -> 5c3604d9b
BUGFIX: HDFSFileTopology should use the 3rd ags as topologyName.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5c3604d9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5c3604d9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5c3604d9
Branch: refs/heads/1.x-branch
Commit: 5c3604d9bce8dd9a6afa1a3dd13fba417800e3fd
Parents: f9d561a
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Sep 18 13:18:08 2014 -0700
Committer: Sivaguru Kannan <sc...@hortonworks.com>
Committed: Thu Jun 16 13:21:07 2016 -0700
----------------------------------------------------------------------
.../test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/5c3604d9/external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java b/external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java
index 7409cc4..b1ae542 100644
--- a/external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java
+++ b/external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java
@@ -106,9 +106,9 @@ public class HdfsFileTopology {
cluster.shutdown();
System.exit(0);
} else if (args.length == 3) {
- StormSubmitter.submitTopology(args[0], config, builder.createTopology());
+ StormSubmitter.submitTopology(args[2], config, builder.createTopology());
} else{
- System.out.println("Usage: HdfsFileTopology [topology name] <yaml config file>");
+ System.out.println("Usage: HdfsFileTopology [hdfs url] [hdfs yaml config file] <topology name>");
}
}