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:47:44 UTC
[1/2] 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/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 <da...@datatorrent.com>
Authored: Tue Mar 22 17:23:58 2016 -0700
Committer: David Yan <da...@datatorrent.com>
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)
[2/2] incubator-apex-core git commit: Merge branch 'APEXCORE-403' of
github.com:davidyan74/incubator-apex-core
Posted by pr...@apache.org.
Merge branch 'APEXCORE-403' of github.com:davidyan74/incubator-apex-core
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/48709d99
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/48709d99
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/48709d99
Branch: refs/heads/master
Commit: 48709d995f959cb15c8dc7e6d13be00c826b1b36
Parents: 0f1e2bb 53aa51e
Author: Pramod Immaneni <pr...@datatorrent.com>
Authored: Wed Mar 23 15:38:39 2016 -0700
Committer: Pramod Immaneni <pr...@datatorrent.com>
Committed: Wed Mar 23 15:38:39 2016 -0700
----------------------------------------------------------------------
.../com/datatorrent/stram/plan/logical/DelayOperatorTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------