You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2017/06/08 20:10:46 UTC
kafka git commit: HOTFIX: for flaky Streams EOS integration tests
Repository: kafka
Updated Branches:
refs/heads/trunk b4b65e9ea -> 21194a63e
HOTFIX: for flaky Streams EOS integration tests
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Guozhang Wang <wa...@gmail.com>, Jason Gustafson <ja...@confluent.io>
Closes #3273 from mjsax/hotfix-flaky-stream-eos-test
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/21194a63
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/21194a63
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/21194a63
Branch: refs/heads/trunk
Commit: 21194a63edb460105acd8763e03d07ebbff1df68
Parents: b4b65e9
Author: Matthias J. Sax <ma...@confluent.io>
Authored: Thu Jun 8 13:10:34 2017 -0700
Committer: Jason Gustafson <ja...@confluent.io>
Committed: Thu Jun 8 13:10:34 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/21194a63/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;