gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ibuen...@apache.org
Subject incubator-gobblin git commit: [GOBBLIN-240] Added three more Azkaban Tags
Date Mon, 11 Sep 2017 16:45:31 GMT
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 <jnchang@linkedin.com>
Authored: Mon Sep 11 09:45:28 2017 -0700
Committer: Issac Buenrostro <ibuenros@apache.org>
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}.


Mime
View raw message