(flink) branch release-2.0 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-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git


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

commit 6dbc563e170ee9d19f967abe4ec209b7bc1a5024
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 40229381558..a99860c4c48 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
@@ -4453,7 +4453,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.")