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:09:00 UTC
(flink) branch release-2.1 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 release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.1 by this push:
new 0030ad3c743 [FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang
0030ad3c743 is described below
commit 0030ad3c743211430002a53189f4d6cc60c7563c
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.")