Repository: incubator-apex-core Updated Branches: refs/heads/master 0f1e2bb03 -> 48709d995
APEXCORE-403 #resolve Added volatile keyword to failureSimulated variable because it's written and read by different threads Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/53aa51ec Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/53aa51ec Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/53aa51ec Branch: refs/heads/master Commit: 53aa51ec9755e536a805067dabc01d8c24f23425 Parents: 8549664 Author: David Yan <[email protected]> Authored: Tue Mar 22 17:23:58 2016 -0700 Committer: David Yan <[email protected]> Committed: Wed Mar 23 15:28:36 2016 -0700 ---------------------------------------------------------------------- .../com/datatorrent/stram/plan/logical/DelayOperatorTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/53aa51ec/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 javax.validation.ValidationException; 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 @@ public class DelayOperatorTest 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)
