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 <[email protected]> Authored: Mon Feb 2 15:45:57 2015 -0800 Committer: Sriharsha Chintalapani <[email protected]> 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);
