SAMZA-1326: Revert to use getGlobalAppId for zk path
authorBoris Shkolnik <boryas@apache.org>
Wed, 7 Jun 2017 21:23:13 +0000 (14:23 -0700)
committernavina <navina@apache.org>
Wed, 7 Jun 2017 21:23:13 +0000 (14:23 -0700)
Author: Boris Shkolnik <boryas@apache.org>

Reviewers: Navina Ramesh <navina@apache.org>

Closes #216 from sborya/getGlobalId

samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java

index 5e46ce5..a0558ef 100644 (file)
@@ -65,7 +65,7 @@ public class ZkJobCoordinator implements JobCoordinator, ZkControllerListener {
   public ZkJobCoordinator(Config config) {
     this.config = config;
     ZkConfig zkConfig = new ZkConfig(config);
-    ZkKeyBuilder keyBuilder = new ZkKeyBuilder(new ApplicationConfig(config).getAppId());
+    ZkKeyBuilder keyBuilder = new ZkKeyBuilder(new ApplicationConfig(config).getGlobalAppId());
     this.zkUtils = new ZkUtils(
         keyBuilder,
         ZkCoordinationServiceFactory.createZkClient(