(flink) branch release-1.20 updated: [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang

[fanrui]

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

fanrui pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.20 by this push:
     new 9749b810e74 [FLINK-38642][checkpoint] Specify thread pool to avoid 
CheckpointCoordinatorTest hang
9749b810e74 is described below

commit 9749b810e74bdf2d855d82f88278afabf28cd520
Author: Rui Fan <fan...@apache.org>
AuthorDate: Fri Nov 7 10:31:01 2025 +0100

    [FLINK-38642][checkpoint] Specify thread pool to avoid 
CheckpointCoordinatorTest hang
---
 .../org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
index c2d2144a1fd..e91f524ed54 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
@@ -4448,7 +4448,8 @@ class CheckpointCoordinatorTest {
                             } catch (Exception e) {
                                 throw new RuntimeException(e);
                             }
-                        });
+                        },
+                        EXECUTOR_RESOURCE.getExecutor());
 
         assertThat(tracker.getReportStartedFuture().get(TIMEOUT_SECONDS, 
TimeUnit.SECONDS))
                 .as("reportCompletedCheckpoint should be started soon when 
checkpoint is acked.")