Repository: kafka Updated Branches: refs/heads/trunk c57cfdf4f -> 88aec3eb6
MINOR: disable flaky Streams EOS integration tests Author: Matthias J. Sax <matth...@confluent.io> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #3272 from mjsax/minor-disable-eos-tests Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/88aec3eb Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/88aec3eb Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/88aec3eb Branch: refs/heads/trunk Commit: 88aec3eb6d6f8d328e322493ebf4c3011b7335ea Parents: c57cfdf Author: Matthias J. Sax <matth...@confluent.io> Authored: Thu Jun 8 15:32:45 2017 -0700 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Thu Jun 8 15:32:45 2017 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/streams/integration/EosIntegrationTest.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/88aec3eb/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 e105cdc..2141cbe 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 @@ -45,6 +45,7 @@ import org.apache.kafka.test.TestCondition; import org.apache.kafka.test.TestUtils; import org.junit.Before; import org.junit.ClassRule; +import org.junit.Ignore; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -311,6 +312,7 @@ public class EosIntegrationTest { } } + @Ignore @Test public void shouldNotViolateEosIfOneTaskFails() throws Exception { // this test writes 10 + 5 + 5 records per partition (running with 2 parttions) @@ -587,6 +589,7 @@ public class EosIntegrationTest { ); } + @Ignore @Test public void shouldNotViolateEosIfOneTaskFailsWithState() throws Exception { // this test updates a store with 10 + 5 + 5 records per partition (running with 2 partitions)
