openstack/monasca-thresh
Code Issues Proposed changes

Merge "Revert "Use external Zookeeper in Local mode""

Browse Source
This commit is contained in:
Zuul 2021-06-07 15:35:26 +00:00 committed by Gerrit Code Review
commit d256f05be6
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) {
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);