openstack/monasca-thresh
Code Issues Proposed changes

Revert "Use external Zookeeper in Local mode"

Browse Source 
This reverts commit d156980a52.

Change-Id: I8a0bbf34db9d25503e50d4ef9d9da466f229fc78
This commit is contained in:
Martin Chacon Piza 2021-05-27 16:14:12 +02:00
parent d156980a52
commit 37ccf62158
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
thresh/src/main/java/monasca/thresh/ThresholdingEngine.java
View File

@ -102,10 +102,7 @@ public class ThresholdingEngine {
if (local) { if (local) {
logger.info("submitting topology {} to local storm cluster", topologyName); logger.info("submitting topology {} to local storm cluster", topologyName);
new LocalCluster( new LocalCluster().submitTopology(topologyName, config, topology);
System.getenv("ZOOKEEPER_SERVERS"),
new Long(System.getenv("ZOOKEEPER_PORT"))
).submitTopology(topologyName, config, topology);
} else { } else {
logger.info("submitting topology {} to non-local storm cluster", topologyName); logger.info("submitting topology {} to non-local storm cluster", topologyName);
StormSubmitter.submitTopology(topologyName, config, topology); StormSubmitter.submitTopology(topologyName, config, topology);