Repository: incubator-gobblin Updated Branches: refs/heads/master adc669fee -> afdba01f9
[GOBBLIN-240] Added three more Azkaban Tags Closes #2091 from jinhyukchang/master Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/afdba01f Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/afdba01f Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/afdba01f Branch: refs/heads/master Commit: afdba01f904609acb41f955f4e513aacf7b7f96f Parents: adc669f Author: Jin Hyuk Chang <[email protected]> Authored: Mon Sep 11 09:45:28 2017 -0700 Committer: Issac Buenrostro <[email protected]> Committed: Mon Sep 11 09:45:28 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/gobblin/util/AzkabanTags.java | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/afdba01f/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 fc9522a..80c3cb6 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 @@ -37,7 +37,11 @@ public class AzkabanTags { .put("azkaban.flow.flowid", "azkabanFlowId") .put("azkaban.job.id", "azkabanJobId") .put("azkaban.flow.execid", "azkabanExecId") - .put("azkaban.link.execution.url", "azkabanURL").build(); + .put("azkaban.link.execution.url", "azkabanURL") + .put("azkaban.link.workflow.url", "azkabanFlowURL") + .put("azkaban.link.job.url", "azkabanJobURL") + .put("azkaban.link.jobexec.url", "azkabanJobExecURL") + .build(); /** * Uses {@link #getAzkabanTags(Configuration)} with default Hadoop {@link Configuration} @@ -48,6 +52,14 @@ public class AzkabanTags { /** * Gets all useful Azkaban runtime properties required by metrics as a {@link Map}. + * Below metrics will be fetched if available: + * - azkabanFlowId : name of Azkaban flow + * - azkabanFlowURL : URL of Azkaban flow + * - azkabanURL : URL of Azkaban flow execution + * - azkabanExecId : ID of flow execution + * - azkabanJobId : name of Azkaban job + * - azkabanJobURL : URL of Azkaban job + * - azkabanJobExecURL : URL of Azkaban job execution * * @param conf Hadoop Configuration that contains the properties. Keys of {@link #PROPERTIES_TO_TAGS_MAP} lists out * all the properties to look for in {@link Configuration}.
