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 2015/02/20 05:07:04 UTC
[1/2] storm git commit: STORM-648. storm examples BasicDRPCTopology
fails without running.
Repository: storm
Updated Branches:
refs/heads/STORM-648 [created] a16d1404f
STORM-648. storm examples BasicDRPCTopology fails without running.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5eefcfbe
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5eefcfbe
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5eefcfbe
Branch: refs/heads/STORM-648
Commit: 5eefcfbe331d54216850041a3268d45a20d1933e
Parents: 103de9a
Author: Sriharsha Chintalapani <ma...@harsha.io>
Authored: Mon Feb 2 15:45:57 2015 -0800
Committer: Sriharsha Chintalapani <ma...@harsha.io>
Committed: Mon Feb 2 15:45:57 2015 -0800
----------------------------------------------------------------------
.../storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/5eefcfbe/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java b/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java
index 1b29738..a12b017 100644
--- a/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java
+++ b/examples/storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java
@@ -67,8 +67,9 @@ public class BasicDRPCTopology {
System.out.println("Result for \"" + word + "\": " + drpc.execute("exclamation", word));
}
- cluster.shutdown();
+ Thread.sleep(10000);
drpc.shutdown();
+ cluster.shutdown();
}
else {
conf.setNumWorkers(3);
[2/2] storm git commit: Merge branch 'STORM-648' of
https://github.com/harshach/incubator-storm into STORM-648
Posted by sr...@apache.org.
Merge branch 'STORM-648' of https://github.com/harshach/incubator-storm into STORM-648
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a16d1404
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a16d1404
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a16d1404
Branch: refs/heads/STORM-648
Commit: a16d1404f856934b89349e137be4004ce24104e0
Parents: 05d3ccf 5eefcfb
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Thu Feb 19 19:51:33 2015 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Thu Feb 19 19:51:33 2015 -0800
----------------------------------------------------------------------
.../storm-starter/src/jvm/storm/starter/BasicDRPCTopology.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------