You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/11/01 17:30:17 UTC
kafka git commit: KAFKA-4352: instable ResetTool integration test
Repository: kafka
Updated Branches:
refs/heads/trunk ba322e542 -> fbbe5821c
KAFKA-4352: instable ResetTool integration test
- increased timeout to stabilize test
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Eno Thereska, Guozhang Wang
Closes #2082 from mjsax/kafka-4352-hotfix
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fbbe5821
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fbbe5821
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fbbe5821
Branch: refs/heads/trunk
Commit: fbbe5821c26d5e4c7d0dff130ea722fbf90169d8
Parents: ba322e5
Author: Matthias J. Sax <ma...@confluent.io>
Authored: Tue Nov 1 10:30:13 2016 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Nov 1 10:30:13 2016 -0700
----------------------------------------------------------------------
.../apache/kafka/streams/integration/ResetIntegrationTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/fbbe5821/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 110bfba..4bc74ae 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
@@ -149,7 +149,8 @@ public class ResetIntegrationTest {
final List<KeyValue<Long, Long>> resultRerun = IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(
resultTopicConsumerConfig,
OUTPUT_TOPIC,
- 10);
+ 10,
+ 60000);
final KeyValue<Object, Object> resultRerun2 = IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(
resultTopicConsumerConfig,
OUTPUT_TOPIC_2_RERUN,