kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-4352: instable ResetTool integration test
Date Tue, 01 Nov 2016 17:31:10 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 f3e5e6d65 -> fc6540023


KAFKA-4352: instable ResetTool integration test

 - increased timeout to stabilize test

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

Reviewers: Eno Thereska, Guozhang Wang

Closes #2082 from mjsax/kafka-4352-hotfix

(cherry picked from commit fbbe5821c26d5e4c7d0dff130ea722fbf90169d8)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.10.1
Commit: fc6540023b08344b8b2cdb8ce3253ba859668793
Parents: f3e5e6d
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Tue Nov 1 10:30:13 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Nov 1 10:31:08 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/fc654002/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 5847fb1..d07970f 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
@@ -148,7 +148,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,


Mime
View raw message