(paimon) branch master updated: [hotfix] Fix unstable test in BucketedSortedIndexMaintainerTest

[lzljs3620320]

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

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 55e4358d8e [hotfix] Fix unstable test in 
BucketedSortedIndexMaintainerTest
55e4358d8e is described below

commit 55e4358d8e62f99b1c3800fab19b2cbd486e3eec
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Mon Jul 13 22:40:54 2026 +0800

    [hotfix] Fix unstable test in BucketedSortedIndexMaintainerTest
---
 .../paimon/index/pksorted/BucketedSortedIndexMaintainerTest.java      | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/paimon-core/src/test/java/org/apache/paimon/index/pksorted/BucketedSortedIndexMaintainerTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/index/pksorted/BucketedSortedIndexMaintainerTest.java
index 167faddce8..835c686b36 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/index/pksorted/BucketedSortedIndexMaintainerTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/index/pksorted/BucketedSortedIndexMaintainerTest.java
@@ -232,7 +232,6 @@ class BucketedSortedIndexMaintainerTest {
                 Arrays.asList(payload("new-1", source, 2), payload("new-2", 
source, 1));
         CountDownLatch started = new CountDownLatch(1);
         CountDownLatch release = new CountDownLatch(1);
-        CountDownLatch completed = new CountDownLatch(1);
         BucketedSortedIndexMaintainer maintainer =
                 new BucketedSortedIndexMaintainer(
                         7,
@@ -241,7 +240,6 @@ class BucketedSortedIndexMaintainerTest {
                         dataFile -> {
                             started.countDown();
                             release.await();
-                            completed.countDown();
                             return payloads;
                         },
                         Collections.emptyList(),
@@ -256,7 +254,7 @@ class BucketedSortedIndexMaintainerTest {
         assertThat(maintainer.buildNotCompleted()).isTrue();
 
         release.countDown();
-        assertThat(completed.await(5, TimeUnit.SECONDS)).isTrue();
+        executor.submit(() -> {}).get(5, TimeUnit.SECONDS);
         BucketedSortedIndexMaintainer.SortedIndexCommit second =
                 maintainer.prepareCommit(
                         DataIncrement.emptyIncrement(), 
CompactIncrement.emptyIncrement(), false);