Repository: incubator-gobblin Updated Branches: refs/heads/master d75d8fbb5 -> e66b8a66c
[GOBBLIN-626] Fix the job planning tag key Closes #2496 from kyuamazon/disttag2 Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/e66b8a66 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/e66b8a66 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/e66b8a66 Branch: refs/heads/master Commit: e66b8a66c8e2e445037e467a006070bbf62acc9a Parents: d75d8fb Author: Kuai Yu <[email protected]> Authored: Mon Nov 5 15:31:58 2018 -0800 Committer: Hung Tran <[email protected]> Committed: Mon Nov 5 15:31:58 2018 -0800 ---------------------------------------------------------------------- .../cluster/GobblinHelixDistributeJobExecutionLauncher.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/e66b8a66/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java index 707bdca..e01ab28 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java @@ -211,9 +211,9 @@ class GobblinHelixDistributeJobExecutionLauncher implements JobExecutionLauncher // Planning job should have its own tag support if (jobProps.containsKey(GobblinClusterConfigurationKeys.HELIX_PLANNING_JOB_TAG_KEY)) { - String jobTag = jobProps.getProperty(GobblinClusterConfigurationKeys.HELIX_JOB_TAG_KEY); - log.info("PlanningJob {} has tags associated : {}", planningId, jobTag); - jobConfigBuilder.setInstanceGroupTag(jobTag); + String jobPlanningTag = jobProps.getProperty(GobblinClusterConfigurationKeys.HELIX_PLANNING_JOB_TAG_KEY); + log.info("PlanningJob {} has tags associated : {}", planningId, jobPlanningTag); + jobConfigBuilder.setInstanceGroupTag(jobPlanningTag); } jobConfigBuilder.setNumConcurrentTasksPerInstance(PropertiesUtils.getPropAsInt(jobProps,
