diff --git a/thresh/src/main/java/monasca/thresh/ThresholdingEngine.java b/thresh/src/main/java/monasca/thresh/ThresholdingEngine.java
index c76cae5..29130a6 100644
--- a/thresh/src/main/java/monasca/thresh/ThresholdingEngine.java
+++ b/thresh/src/main/java/monasca/thresh/ThresholdingEngine.java
@@ -102,10 +102,7 @@ public class ThresholdingEngine {
 
     if (local) {
       logger.info("submitting topology {} to local storm cluster", topologyName);
-      new LocalCluster(
-          System.getenv("ZOOKEEPER_SERVERS"),
-          new Long(System.getenv("ZOOKEEPER_PORT"))
-      ).submitTopology(topologyName, config, topology);
+      new LocalCluster().submitTopology(topologyName, config, topology);
     } else {
       logger.info("submitting topology {} to non-local storm cluster", topologyName);
       StormSubmitter.submitTopology(topologyName, config, topology);