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/05/04 06:18:09 UTC
samza git commit: SAMZA-1224 : Revert job coordinator factory config
to the old format
Repository: samza
Updated Branches:
refs/heads/master 06b5dbdae -> f99de20cc
SAMZA-1224 : Revert job coordinator factory config to the old format
We didn't release since adding this config. So, it is ok to change the format now.
Author: nramesh <nr...@linkedin.com>
Reviewers: Xinyu Liu <xi...@linkedin.com>, Prateek Maheshwari <pm...@linkedin.com>
Closes #146 from navina/SAMZA-1224
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/f99de20c
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/f99de20c
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/f99de20c
Branch: refs/heads/master
Commit: f99de20cca3bde199742290e9b54b6776e7ee46d
Parents: 06b5dbd
Author: Navina Ramesh <na...@apache.org>
Authored: Wed May 3 23:17:59 2017 -0700
Committer: nramesh <nr...@linkedin.com>
Committed: Wed May 3 23:17:59 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/samza/config/JobCoordinatorConfig.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/f99de20c/samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java
----------------------------------------------------------------------
diff --git a/samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java b/samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java
index e0c599d..c03df06 100644
--- a/samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java
+++ b/samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java
@@ -22,8 +22,8 @@ package org.apache.samza.config;
import com.google.common.base.Strings;
public class JobCoordinatorConfig extends MapConfig {
- public static final String JOB_COORDINATOR_FACTORY = "job-coordinator.factory";
- public static final String JOB_COORDINATIOIN_SERVICE_FACTORY = "job-coordinationService.factory";
+ public static final String JOB_COORDINATOR_FACTORY = "job.coordinator.factory";
+ public static final String JOB_COORDINATIOIN_SERVICE_FACTORY = "job.coordinationService.factory";
public JobCoordinatorConfig(Config config) {
super(config);