You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by na...@apache.org on 2017/06/07 21:23:25 UTC
samza git commit: SAMZA-1326: Revert to use getGlobalAppId for zk path
Repository: samza
Updated Branches:
refs/heads/master c1c4289c8 -> 451b2e538
SAMZA-1326: Revert to use getGlobalAppId for zk path
Author: Boris Shkolnik <bo...@apache.org>
Reviewers: Navina Ramesh <na...@apache.org>
Closes #216 from sborya/getGlobalId
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/451b2e53
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/451b2e53
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/451b2e53
Branch: refs/heads/master
Commit: 451b2e538611c51c25579e2cab106c241f4eaf52
Parents: c1c4289
Author: Boris Shkolnik <bo...@apache.org>
Authored: Wed Jun 7 14:23:13 2017 -0700
Committer: navina <na...@apache.org>
Committed: Wed Jun 7 14:23:13 2017 -0700
----------------------------------------------------------------------
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/451b2e53/samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
----------------------------------------------------------------------
diff --git a/samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java b/samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
index 5e46ce5..a0558ef 100644
--- a/samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
+++ b/samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
@@ -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(