davidradl commented on code in PR #27484:
URL: https://github.com/apache/flink/pull/27484#discussion_r2735745503
##########
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##########
@@ -527,6 +527,28 @@ public class CheckpointingOptions {
CHECKPOINTING_INTERVAL_DURING_BACKLOG.key()))
.build());
+ /**
+ * The initial delay before the first checkpoint is triggered after the
job starts.
+ *
+ * <p>This is useful for jobs that need time to warm up or catch up with
backlogs before
+ * performing the first checkpoint.
+ */
+ @PublicEvolving
+ public static final ConfigOption<Duration> CHECKPOINTING_INITIAL_DELAY =
+ ConfigOptions.key("execution.checkpointing.initial-delay")
+ .durationType()
+ .defaultValue(Duration.ZERO)
+ .withDescription(
+ Description.builder()
+ .text(
+ "The initial delay before the
first checkpoint is triggered after the job starts. "
+ + "This is useful for jobs
that need time to warm up or catch up with backlogs. "
+ + "If set to 0 (default),
the initial delay will be randomly chosen between "
Review Comment:
I wonder if it would be better to have this as a random jitter above the
minimum pause. Otherwise we could randomly get a very long delay for the first
checkpoint if CHECKPOINTING_INTERVAL is large.
--
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]
