kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: for flaky Streams EOS integration tests
Date Thu, 08 Jun 2017 20:10:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 313560eaa -> c6a6ddfa9


HOTFIX: for flaky Streams EOS integration tests

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Jason Gustafson <jason@confluent.io>

Closes #3273 from mjsax/hotfix-flaky-stream-eos-test

(cherry picked from commit 21194a63edb460105acd8763e03d07ebbff1df68)
Signed-off-by: Jason Gustafson <jason@confluent.io>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c6a6ddfa
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c6a6ddfa
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c6a6ddfa

Branch: refs/heads/0.11.0
Commit: c6a6ddfa92a02a53c6ec5f6a81bbaef20d614e23
Parents: 313560e
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Thu Jun 8 13:10:34 2017 -0700
Committer: Jason Gustafson <jason@confluent.io>
Committed: Thu Jun 8 13:10:51 2017 -0700

----------------------------------------------------------------------
 .../org/apache/kafka/streams/integration/EosIntegrationTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/c6a6ddfa/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
index 40bf6a1..e105cdc 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
@@ -81,7 +81,7 @@ public class EosIntegrationTest {
     private final String storeName = "store";
 
     private final Map<Integer, Integer> maxPartitionNumberSeen = Collections.synchronizedMap(new
HashMap<Integer, Integer>());
-    private boolean injectError = false;
+    private volatile boolean injectError = false;
     private AtomicInteger commitRequested;
     private Throwable uncaughtException;
 


Mime
View raw message