[kafka] branch trunk updated: MINOR: increase timeout values in streams tests (#5461)

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new e75048d  MINOR: increase timeout values in streams tests (#5461)
e75048d is described below

commit e75048d3e5344187c3980a2a72793fa9ada3196a
Author: Manikumar Reddy O <manikumar.re...@gmail.com>
AuthorDate: Mon Aug 6 21:43:38 2018 +0530

    MINOR: increase timeout values in streams tests (#5461)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java | 2 +-
 .../apache/kafka/streams/integration/InternalTopicIntegrationTest.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
index 7106aa3..cae0f57 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
@@ -146,7 +146,7 @@ public class GlobalThreadShutDownOrderTest {
             public boolean conditionMet() {
                 return firstRecordProcessed;
             }
-        }, 5000L, "Has not processed record within 5 seconds");
+        }, 10000L, "Has not processed record within 10 seconds");
 
         kafkaStreams.close(30, TimeUnit.SECONDS);
 
diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
index 5eadc6e..a099cea 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
@@ -167,7 +167,7 @@ public class InternalTopicIntegrationTest {
         //
         // Step 3: Verify the state changelog topics are compact
         //
-        waitForCompletion(streams, 2, 5000);
+        waitForCompletion(streams, 2, 10000);
         streams.close();
 
         final Properties changelogProps = 
getTopicProperties(ProcessorStateManager.storeChangelogTopic(appID, "Counts"));