You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2016/03/23 23:51:15 UTC
incubator-apex-core git commit: APEXCORE-403 #resolve Added volatile
keyword to failureSimulated variable because it's written and read by
different threads
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 <da...@datatorrent.com>
Authored: Tue Mar 22 17:23:58 2016 -0700
Committer: Pramod Immaneni <pr...@datatorrent.com>
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)