From b4d90cbc054b4701648555d141ea5f9692f5261a Mon Sep 17 00:00:00 2001
From: Nathan Marz <nathan@twitter.com>
Date: Sun, 23 Oct 2011 15:32:52 -0700
Subject: [PATCH] cleanup a topology

---
 src/jvm/storm/starter/BasicDRPCTopology.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/jvm/storm/starter/BasicDRPCTopology.java b/src/jvm/storm/starter/BasicDRPCTopology.java
index fcd6ee5..718add2 100644
--- 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());