This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 65752d10b29 Fix flaky TableMetadataReaderCompressionTest concurrency
(#19243)
65752d10b29 is described below
commit 65752d10b299fc8e082f0e70276acd811810d91e
Author: Xiang Fu <[email protected]>
AuthorDate: Thu Aug 13 12:38:07 2026 -0700
Fix flaky TableMetadataReaderCompressionTest concurrency (#19243)
---
.../pinot/controller/api/TableMetadataReaderCompressionTest.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/pinot-controller/src/test/java/org/apache/pinot/controller/api/TableMetadataReaderCompressionTest.java
b/pinot-controller/src/test/java/org/apache/pinot/controller/api/TableMetadataReaderCompressionTest.java
index 3927fdbaf48..d5c352d8c8e 100644
---
a/pinot-controller/src/test/java/org/apache/pinot/controller/api/TableMetadataReaderCompressionTest.java
+++
b/pinot-controller/src/test/java/org/apache/pinot/controller/api/TableMetadataReaderCompressionTest.java
@@ -431,11 +431,12 @@ public class TableMetadataReaderCompressionTest {
List.of(segment("segment0", true, 100, 25)));
AtomicInteger preferredRequests = new AtomicInteger();
AtomicInteger fallbackRequests = new AtomicInteger();
- CountDownLatch preferredStarted = new CountDownLatch(1);
+ CountDownLatch preferredStarted = new CountDownLatch(2);
CountDownLatch releasePreferred = new CountDownLatch(1);
CountDownLatch fallbackStarted = new CountDownLatch(1);
+ ExecutorService preferredExecutor = Executors.newFixedThreadPool(2);
HttpServer preferred =
startServer(createBlockingCompressionHandler(currentInfo(), preferredResponse,
- preferredRequests, preferredStarted, releasePreferred));
+ preferredRequests, preferredStarted, releasePreferred),
preferredExecutor);
HttpServer fallback = startServer(createSignalingHandler(currentInfo(),
fallbackResponse, fallbackRequests,
fallbackStarted));
ExecutorService caller = Executors.newSingleThreadExecutor();
@@ -464,6 +465,7 @@ public class TableMetadataReaderCompressionTest {
} finally {
releasePreferred.countDown();
preferred.stop(0);
+ preferredExecutor.shutdownNow();
fallback.stop(0);
caller.shutdownNow();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
