You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2025/11/07 17:07:49 UTC
(flink) branch master updated: [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang
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 <fa...@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.")