diff --git a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
index 4eef247..653349d 100644
--- a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
+++ b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
@@ -61,10 +61,6 @@ public class ProcessJob extends AbstractProcessJob {
public ProcessJob(final String jobId, final Props sysProps,
final Props jobProps, final Logger log) {
super(jobId, sysProps, jobProps, log);
-
- // this is in line with what other job types (hadoopJava, spark, pig, hive)
- // is doing
- jobProps.put(CommonJobProperties.JOB_ID, jobId);
}
@Override
diff --git a/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java b/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
index f421ae3..0c17d1b 100644
--- a/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
+++ b/azkaban-exec-server/src/main/java/azkaban/execapp/JobRunner.java
@@ -599,6 +599,7 @@ public class JobRunner extends EventHandler implements Runnable {
insertJobMetadata();
insertJVMAargs();
+ props.put(CommonJobProperties.JOB_ID, this.jobId);
props.put(CommonJobProperties.JOB_ATTEMPT, node.getAttempt());
props.put(CommonJobProperties.JOB_METADATA_FILE,
createMetaDataFileName(node));