Repository: incubator-apex-core Updated Branches: refs/heads/release-3.3 5bdb3440b -> 43491b7b3
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/43491b7b Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/43491b7b Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/43491b7b Branch: refs/heads/release-3.3 Commit: 43491b7b32c68c5d4fc0c10821c646888e1b929f Parents: 5bdb344 Author: David Yan <[email protected]> Authored: Tue Mar 22 17:23:58 2016 -0700 Committer: Pramod Immaneni <[email protected]> Committed: Wed Mar 23 15:49:20 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/43491b7b/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)
