Repository: incubator-gobblin Updated Branches: refs/heads/master 3a035737f -> fdb233d61
[GOBBLIN-252] Add some azkaban constants Closes #2103 from yukuai518/azkabanconfig Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/fdb233d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/fdb233d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/fdb233d6 Branch: refs/heads/master Commit: fdb233d61135613cb755f1c4abbd9f2e02a80f95 Parents: 3a03573 Author: Kuai Yu <[email protected]> Authored: Thu Sep 14 16:04:20 2017 -0700 Committer: Hung Tran <[email protected]> Committed: Thu Sep 14 16:04:20 2017 -0700 ---------------------------------------------------------------------- .../gobblin/configuration/ConfigurationKeys.java | 8 ++++++++ .../java/org/apache/gobblin/util/AzkabanTags.java | 17 +++++++++-------- 2 files changed, 17 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fdb233d6/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java index 32d4729..224064d 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java @@ -772,6 +772,14 @@ public class ConfigurationKeys { */ public static final String AZKABAN_EXECUTION_TIME_RANGE = "azkaban.execution.time.range"; public static final String AZKABAN_EXECUTION_DAYS_LIST = "azkaban.execution.days.list"; + public static final String AZKABAN_PROJECT_NAME = "azkaban.flow.projectname"; + public static final String AZKABAN_FLOW_ID = "azkaban.flow.flowid"; + public static final String AZKABAN_JOB_ID = "azkaban.job.id"; + public static final String AZKABAN_EXEC_ID = "azkaban.flow.execid"; + public static final String AZKABAN_URL = "azkaban.link.execution.url"; + public static final String AZKABAN_FLOW_URL = "azkaban.link.workflow.url"; + public static final String AZKABAN_JOB_URL = "azkaban.link.job.url"; + public static final String AZKABAN_JOB_EXEC_URL = "azkaban.link.jobexec.url"; /** * Hive registration properties http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fdb233d6/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java index 80c3cb6..e629c37 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java @@ -21,6 +21,7 @@ import java.util.Map; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; import org.apache.hadoop.conf.Configuration; import com.google.common.collect.ImmutableMap; @@ -33,14 +34,14 @@ import com.google.common.collect.Maps; public class AzkabanTags { public static final ImmutableMap<String, String> PROPERTIES_TO_TAGS_MAP = new ImmutableMap.Builder<String, String>() - .put("azkaban.flow.projectname", "azkabanProjectName") - .put("azkaban.flow.flowid", "azkabanFlowId") - .put("azkaban.job.id", "azkabanJobId") - .put("azkaban.flow.execid", "azkabanExecId") - .put("azkaban.link.execution.url", "azkabanURL") - .put("azkaban.link.workflow.url", "azkabanFlowURL") - .put("azkaban.link.job.url", "azkabanJobURL") - .put("azkaban.link.jobexec.url", "azkabanJobExecURL") + .put(ConfigurationKeys.AZKABAN_PROJECT_NAME, "azkabanProjectName") + .put(ConfigurationKeys.AZKABAN_FLOW_ID, "azkabanFlowId") + .put(ConfigurationKeys.AZKABAN_JOB_ID, "azkabanJobId") + .put(ConfigurationKeys.AZKABAN_EXEC_ID, "azkabanExecId") + .put(ConfigurationKeys.AZKABAN_URL, "azkabanURL") + .put(ConfigurationKeys.AZKABAN_FLOW_URL, "azkabanFlowURL") + .put(ConfigurationKeys.AZKABAN_JOB_URL, "azkabanJobURL") + .put(ConfigurationKeys.AZKABAN_JOB_EXEC_URL, "azkabanJobExecURL") .build(); /**
