Mercurial > hg > Database > Christie
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);