kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: disable flaky Streams EOS integration tests
Date Thu, 08 Jun 2017 22:32:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk c57cfdf4f -> 88aec3eb6


MINOR: disable flaky Streams EOS integration tests

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

Reviewers: Guozhang Wang <wangguoz@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 <matthias@confluent.io>
Authored: Thu Jun 8 15:32:45 2017 -0700
Committer: Guozhang Wang <wangguoz@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)


Mime
View raw message