commit 43491b7b32c68c5d4fc0c10821c646888e1b929f
author David Yan <david@datatorrent.com> Tue Mar 22 17:23:58 2016 -0700
committer Pramod Immaneni <pramod@datatorrent.com> Wed Mar 23 15:49:20 2016 -0700
tree be6cfb1cc61ce341d9d15c2466e6d9497fc9bbe8
parent 5bdb3440b0f78c6365352433bd6b76d4b2a95587

APEXCORE-403 #resolve Added volatile keyword to failureSimulated variable because it's written and read by different threads

engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java

diff --git a/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java b/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
index 20f032c..b6d6909 100644
--- a/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
+++ b/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
@@ -35,7 +35,6 @@
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
-import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 
@@ -263,7 +262,7 @@
     private int simulateFailureWindows = 0;
     private boolean simulateFailureAfterCommit = false;
     private int windowCount = 0;
-    private static boolean failureSimulated = false;
+    private static volatile boolean failureSimulated = false;
 
     @Override
     public void beginWindow(long windowId)