diff src/main/java/christie/topology/manager/ConfigWaiter.java @ 121:8949d0ecf1f6

refactor Topology
author akahori
date Tue, 11 Dec 2018 15:46:09 +0900
parents e2ce8038815a
children a0391cfdcef6
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/ConfigWaiter.java	Tue Dec 11 15:43:45 2018 +0900
+++ b/src/main/java/christie/topology/manager/ConfigWaiter.java	Tue Dec 11 15:46:09 2018 +0900
@@ -25,6 +25,7 @@
     protected void run(CodeGearManager cgm) {
         nodeNum--;
         if (nodeNum == 0) {
+            getLocalDGM().put("start", "start");
             for (String nodeName: waiterNodeNames) getDGM(nodeName).put("start", "start");
             getLocalDGM().put("startTime", System.currentTimeMillis());
             getLocalDGM().put("running", true);