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(