From 88e6a683b42bd4fd48b5e954c4d37ebc2a23d91e Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Tue, 20 Aug 2024 21:30:54 -0700 Subject: [PATCH] fix flaky ParallelMergeCombiningSequenceTest.testTimeoutExceptionDueToStoppedReader when runner is very slow --- .../common/guava/ParallelMergeCombiningSequenceTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/processing/src/test/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequenceTest.java b/processing/src/test/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequenceTest.java index 293943dcca9d..cbe84cb4eec1 100644 --- a/processing/src/test/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequenceTest.java +++ b/processing/src/test/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequenceTest.java @@ -573,6 +573,7 @@ public void testTimeoutExceptionDueToSlowReader() public void testTimeoutExceptionDueToStoppedReader() throws InterruptedException { final int someSize = 150_000; + final int timeout = 5_000; List reporters = new ArrayList<>(); for (int i = 0; i < 100; i++) { List> input = new ArrayList<>(); @@ -588,7 +589,7 @@ public void testTimeoutExceptionDueToStoppedReader() throws InterruptedException INT_PAIR_ORDERING, INT_PAIR_MERGE_FN, true, - 1000, + timeout, 0, TEST_POOL_SIZE, 512, @@ -605,7 +606,7 @@ public void testTimeoutExceptionDueToStoppedReader() throws InterruptedException } // sleep until timeout - Thread.sleep(5000); + Thread.sleep(timeout); Assert.assertTrue(pool.awaitQuiescence(10, TimeUnit.SECONDS)); Assert.assertTrue(pool.isQuiescent()); Assert.assertFalse(pool.hasQueuedSubmissions());