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 d584aca commit 978b8a2Copy full SHA for 978b8a2
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java
@@ -1535,9 +1535,12 @@ private void checkIdleSlotTimeout() {
1535
TimeUnit.MILLISECONDS);
1536
}
1537
1538
+ /**
1539
+ * Wrapper class implementing {@link CheckpointStatsListener} in a way that checkpoint-related
1540
+ * events are actually executed in the {@code AdaptiveScheduler}'s main thread.
1541
+ */
1542
private CheckpointStatsListener createCheckpointStatsListener() {
- // wrapper implementation ensuring that the checkpoint-related events are handled in the
- // scheduler's main thread
1543
+
1544
return new CheckpointStatsListener() {
1545
1546
@Override
0 commit comments