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();