azkaban-aplcache

Formatting and documentation

6/17/2014 2:54:24 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutableFlow.java b/azkaban-common/src/main/java/azkaban/executor/ExecutableFlow.java
index 7f87670..5a77a3e 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutableFlow.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutableFlow.java
@@ -37,7 +37,7 @@ public class ExecutableFlow extends ExecutableFlowBase {
   public static final String SUBMITTIME_PARAM = "submitTime";
   public static final String VERSION_PARAM = "version";
   public static final String PROXYUSERS_PARAM = "proxyUsers";
-  private static final String PROJECTNAME_PARAM = "projectName";
+  public static final String PROJECTNAME_PARAM = "projectName";
 
   private int executionId = -1;
   private int scheduleId = -1;
diff --git a/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java b/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
index e5bf248..3d9a0b1 100644
--- a/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
+++ b/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
@@ -521,11 +521,16 @@ public class JobRunner extends EventHandler implements Runnable {
     return true;
   }
 
+  /**
+   * Add relevant links to the job properties so that downstream consumers may
+   * know what executions initiated their execution.
+   */
   private void insertLinks() {
     Props azkProps = AzkabanExecutorServer.getApp().getAzkabanProps();
     String baseURL = azkProps.get("azkaban.webserver.url");
-    if (baseURL == null)
+    if (baseURL == null){
       return;
+    }
 
     String flowName = node.getParentFlow().getFlowId();
     String projectName = node.getParentFlow().getProjectName();