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


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

commit 0355bdeee64bf3974d922a028ddae6fdffe751a2
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 7cd736108a6..f64672fc329 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.")