diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java index 7b95ee40160c60..902bfbe8b7a4ef 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java @@ -1528,9 +1528,12 @@ private void checkIdleSlotTimeout() { TimeUnit.MILLISECONDS); } + /** + * Wrapper class implementing {@link CheckpointStatsListener} in a way that checkpoint-related + * events are actually executed in the {@code AdaptiveScheduler}'s main thread. + */ private CheckpointStatsListener createCheckpointStatsListener() { - // wrapper implementation ensuring that the checkpoint-related events are handled in the - // scheduler's main thread + return new CheckpointStatsListener() { @Override