pnowojski commented on code in PR #27782:
URL: https://github.com/apache/flink/pull/27782#discussion_r2974141654
##########
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##########
@@ -668,6 +669,40 @@ public class CheckpointingOptions {
"Whether recovering output buffers of upstream
task on downstream task directly "
+ "when job restores from the unaligned
checkpoint.");
+ /**
+ * Whether to enable checkpointing during recovery from an unaligned
checkpoint.
+ *
+ * <p>When enabled, the job can take checkpoints while still recovering
channel state (inflight
+ * data) from a previous unaligned checkpoint. This avoids the need to
wait for full recovery
+ * before the first checkpoint can be triggered, which reduces the window
of vulnerability to
+ * failures during recovery.
+ *
+ * <p>This option requires {@link #UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM}
to be enabled. It
+ * does not require unaligned checkpoints to be currently enabled, because
a job may restore
+ * from an unaligned checkpoint while having unaligned checkpoints
disabled for the new
+ * execution.
+ */
Review Comment:
nit: shouldn't this be copied into the description?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
