diff --git a/paimon-core/src/test/java/org/apache/paimon/crosspartition/IndexBootstrapTest.java b/paimon-core/src/test/java/org/apache/paimon/crosspartition/IndexBootstrapTest.java index 50df6e4971ec..a96ee1429740 100644 --- a/paimon-core/src/test/java/org/apache/paimon/crosspartition/IndexBootstrapTest.java +++ b/paimon-core/src/test/java/org/apache/paimon/crosspartition/IndexBootstrapTest.java @@ -97,6 +97,11 @@ public void testBoostrap() throws Exception { .containsExactlyInAnyOrder( GenericRow.of(2, 1, 3), GenericRow.of(4, 2, 5), GenericRow.of(6, 3, 7)); result.clear(); + + // In ParallelExecution, latch.countDown first, then close the reader, it may not be closed + // here, (this is good, beneficial for query speed) but TableTestBase.after will check leak + // streams. So sleep here to avoid unstable. + Thread.sleep(1000); } @Test