[FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang

1996fanrui · 1996fanrui · commit 6dbc563e170e · 2025-11-07T18:09:00.000+01:00
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
@@ -4453,7 +4453,8 @@ void testCompletionFutureCompletesAfterReporting() throws Exception {
                             } 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.")

Original file line number	Diff line number	Diff line change
`@@ -4453,7 +4453,8 @@ void testCompletionFutureCompletesAfterReporting() throws Exception {`
`4453`	`4453`	`} catch (Exception e) {`
`4454`	`4454`	`throw new RuntimeException(e);`
`4455`	`4455`	`}`
`4456`		`- });`
	`4456`	`+ },`
	`4457`	`+ EXECUTOR_RESOURCE.getExecutor());`
`4457`	`4458`
`4458`	`4459`	`assertThat(tracker.getReportStartedFuture().get(TIMEOUT_SECONDS, TimeUnit.SECONDS))`
`4459`	`4460`	`.as("reportCompletedCheckpoint should be started soon when checkpoint is acked.")`