azkaban-developers

Make ExecutableNode.status volatile (#1159) This gives …

6/4/2017 4:34:25 PM

guarantees especially for unit tests that need to check for statuses in a multi-threaded environment. But also FlowRunner thread vs. JobRunner threads benefit from this, although I haven't been able to prove that there would be any critical issues there.

Juho Autio

Commit: 02d36bc

Tree: 2f8af42

Parents: 3eb3ddb

Changes

azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java 2(+1 -1)

Details

azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java 2(+1 -1)

diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java b/azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java
index 34f99bb..a66d9b7 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutableNode.java
@@ -49,7 +49,7 @@ public class ExecutableNode {
   public static final String PASTATTEMPTS_PARAM = "pastAttempts";
   private String id;
   private String type = null;
-  private Status status = Status.READY;
+  private volatile Status status = Status.READY;
   private long startTime = -1;
   private long endTime = -1;
   private long updateTime = -1;