storm-616: fixing number of args for test topologies.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f217096c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f217096c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f217096c Branch: refs/heads/master Commit: f217096cd36383639a7f7384e6ce34c78cf5d954 Parents: 396bc61 Author: Parth Brahmbhatt <[email protected]> Authored: Wed Jan 14 11:42:20 2015 -0800 Committer: Parth Brahmbhatt <[email protected]> Committed: Wed Jan 14 11:42:20 2015 -0800 ---------------------------------------------------------------------- external/storm-jdbc/README.md | 2 +- .../java/org/apache/storm/jdbc/topology/AbstractUserTopology.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/f217096c/external/storm-jdbc/README.md ---------------------------------------------------------------------- diff --git a/external/storm-jdbc/README.md b/external/storm-jdbc/README.md index 79a0d61..4bb5e61 100644 --- a/external/storm-jdbc/README.md +++ b/external/storm-jdbc/README.md @@ -173,7 +173,7 @@ Mysql Example: ``` storm jar ~/repo/incubator-storm/external/storm-jdbc/target/storm-jdbc-0.10.0-SNAPSHOT-jar-with-dependencies.jar org.apache.storm.jdbc.topology.UserPersistanceTridentTopology com.mysql.jdbc.jdbc2.optional.MysqlDataSource -jdbc:mysql://localhost/test root password user UserPersistenceTopology +jdbc:mysql://localhost/test root password UserPersistenceTopology ``` You can execute a select query against the user table which should show newly inserted rows: http://git-wip-us.apache.org/repos/asf/storm/blob/f217096c/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java ---------------------------------------------------------------------- diff --git a/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java b/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java index 700f83e..6d2f8e9 100644 --- a/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java +++ b/external/storm-jdbc/src/test/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java @@ -93,7 +93,7 @@ public abstract class AbstractUserTopology { cluster.shutdown(); System.exit(0); } else { - StormSubmitter.submitTopology(args[5], config, getTopology()); + StormSubmitter.submitTopology(args[4], config, getTopology()); } }
