(kafka) branch trunk updated: MINOR: Flaky RestoreIntegrationTest (#16721)

[mjsax]

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

mjsax 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 4c9795eddf6 MINOR: Flaky RestoreIntegrationTest  (#16721)
4c9795eddf6 is described below

commit 4c9795eddf6ae176dc7ccd1763bb42adc731911e
Author: Bill Bejeck <bbej...@apache.org>
AuthorDate: Tue Aug 6 13:05:10 2024 -0400

    MINOR: Flaky RestoreIntegrationTest  (#16721)
    
    Increase some timeouts to work against race condition.
    
    Reviewers: Matthias J. Sax <matth...@confluent.io>
---
 .../org/apache/kafka/streams/integration/RestoreIntegrationTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
index a71bf93980a..bb2e3a6255e 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
@@ -114,7 +114,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
 public class RestoreIntegrationTest {
     private static final Logger log = 
LoggerFactory.getLogger(RestoreIntegrationTest.class);
 
-    private static final Duration RESTORATION_DELAY = Duration.ofSeconds(1);
+    private static final Duration RESTORATION_DELAY = Duration.ofMillis(500);
 
     private static final int NUM_BROKERS = 1;
 
@@ -580,7 +580,7 @@ public class RestoreIntegrationTest {
         validateReceivedMessages(sampleData, outputTopic);
 
         // Close kafkaStreams1 (with cleanup) and start it again to force the 
restoration of the state.
-        
kafkaStreams.close(Duration.ofMillis(IntegrationTestUtils.DEFAULT_TIMEOUT));
+        kafkaStreams.close(Duration.ofMillis(5000L));
         IntegrationTestUtils.purgeLocalStreamsState(streamsConfigurations);
 
         final TestStateRestoreListener kafkaStreams1StateRestoreListener = new 
TestStateRestoreListener("ks1", RESTORATION_DELAY);