You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/12/06 15:03:10 UTC

kafka git commit: HOTFIX: Temporary suspension of 2 tests

Repository: kafka
Updated Branches:
  refs/heads/trunk f4f0f8222 -> 8fd5b6a66


HOTFIX: Temporary suspension of 2 tests

Author: Eno Thereska <en...@gmail.com>

Reviewers: Ismael Juma <is...@juma.me.uk>

Closes #2199 from enothereska/hotfix-streams-test-reset-ignore


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

Branch: refs/heads/trunk
Commit: 8fd5b6a6669b5e2ba921904596a14936b1317304
Parents: f4f0f82
Author: Eno Thereska <en...@gmail.com>
Authored: Tue Dec 6 15:03:01 2016 +0000
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Tue Dec 6 15:03:01 2016 +0000

----------------------------------------------------------------------
 .../apache/kafka/streams/integration/ResetIntegrationTest.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8fd5b6a6/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java
index 303e3f8..6ed2ffd 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java
@@ -47,7 +47,7 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
-import org.junit.Test;
+import org.junit.Ignore;
 
 import java.util.Collections;
 import java.util.HashSet;
@@ -137,7 +137,7 @@ public class ResetIntegrationTest {
         }
     }
 
-    @Test
+    @Ignore
     public void testReprocessingFromScratchAfterResetWithIntermediateUserTopic() throws Exception {
         CLUSTER.createTopic(INTERMEDIATE_USER_TOPIC);
 
@@ -219,7 +219,7 @@ public class ResetIntegrationTest {
         }
     }
 
-    @Test
+    @Ignore
     public void testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic() throws Exception {
         final Properties streamsConfiguration = prepareTest();
         final Properties resultTopicConsumerConfig = TestUtils.consumerConfig(