cleanup a topology

mpous · Oct 23, 2011 · b4d90cb · b4d90cb
1 parent c2919ad
commit b4d90cb
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/jvm/storm/starter/BasicDRPCTopology.java b/src/jvm/storm/starter/BasicDRPCTopology.java
@@ -48,9 +48,8 @@ public static void main(String[] args) throws Exception {
         builder.addBolt(new ExclaimBolt(), 3);
 
         Config conf = new Config();
-        conf.setDebug(true);
 
-        if(args.length==0) {
+        if(args==null || args.length==0) {
             LocalDRPC drpc = new LocalDRPC();
             LocalCluster cluster = new LocalCluster();
 
@@ -60,6 +59,9 @@ public static void main(String[] args) throws Exception {
                 System.out.println("Result for \"" + word + "\": "
                         + drpc.execute("exclamation", word));
             }
+
+            cluster.shutdown();
+            drpc.shutdown();
         } else {
             conf.setNumWorkers(3);
             StormSubmitter.submitTopology(args[0], conf, builder.createRemoteTopology());