From 63715efa02861b25b3be84c2970342aebec7a439 Mon Sep 17 00:00:00 2001 From: Bill Bejeck Date: Sat, 27 Oct 2018 23:07:40 -0400 Subject: [PATCH] MINOR: Bump timeout for sending records (#5843) Reviewers: John Roesler , Matthias J. Sax --- .../streams/integration/GlobalThreadShutDownOrderTest.java | 2 +- .../streams/integration/InternalTopicIntegrationTest.java | 4 ++-- 2 files changed, 3 insertions(+), 3 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 a0ada62e03f..e0bec90f3ce 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; } - }, 10000L, "Has not processed record within 10 seconds"); + }, 30000, "Has not processed record within 30 seconds"); kafkaStreams.close(Duration.ofSeconds(30)); 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 9bd8c65c2db..8bcaf5d97ec 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 @@ -163,7 +163,7 @@ public class InternalTopicIntegrationTest { // // Step 3: Verify the state changelog topics are compact // - waitForCompletion(streams, 2, 10000); + waitForCompletion(streams, 2, 30000); streams.close(); final Properties changelogProps = getTopicProperties(ProcessorStateManager.storeChangelogTopic(appID, "Counts")); @@ -203,7 +203,7 @@ public class InternalTopicIntegrationTest { // // Step 3: Verify the state changelog topics are compact // - waitForCompletion(streams, 2, 5000); + waitForCompletion(streams, 2, 30000); streams.close(); final Properties properties = getTopicProperties(ProcessorStateManager.storeChangelogTopic(appID, "CountWindows")); final List policies = Arrays.asList(properties.getProperty(LogConfig.CleanupPolicyProp()).split(","));