We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 077d72e commit 6e80ef9Copy full SHA for 6e80ef9
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java
@@ -1528,9 +1528,12 @@ private void checkIdleSlotTimeout() {
1528
TimeUnit.MILLISECONDS);
1529
}
1530
1531
+ /**
1532
+ * Wrapper class implementing {@link CheckpointStatsListener} in a way that checkpoint-related
1533
+ * events are actually executed in the {@code AdaptiveScheduler}'s main thread.
1534
+ */
1535
private CheckpointStatsListener createCheckpointStatsListener() {
- // wrapper implementation ensuring that the checkpoint-related events are handled in the
- // scheduler's main thread
1536
+
1537
return new CheckpointStatsListener() {
1538
1539
@Override
0 commit comments