From 37ccf62158a0c06a9fb199b1feef081b2eabc2fb Mon Sep 17 00:00:00 2001
From: Martin Chacon Piza <martin@chaconpiza.com>
Date: Thu, 27 May 2021 16:14:12 +0200
Subject: [PATCH] Revert "Use external Zookeeper in Local mode"

This reverts commit d156980a528caf1797df1a621719dd76668a18dd.

Change-Id: I8a0bbf34db9d25503e50d4ef9d9da466f229fc78
---
 thresh/src/main/java/monasca/thresh/ThresholdingEngine.java | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

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);