lindong28 commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1303844187
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java:
##########
@@ -126,6 +126,23 @@ public class ExecutionCheckpointingOptions {
.key()))
.build());
+ public static final ConfigOption<Duration>
CHECKPOINTING_INTERVAL_DURING_BACKLOG =
+
ConfigOptions.key("execution.checkpointing.interval-during-backlog")
+ .durationType()
+ .noDefaultValue()
+ .withDescription(
+ Description.builder()
+ .text(
+ "Gets the interval in which
checkpoints are periodically scheduled "
Review Comment:
Should we use the same doc as specified in FLIP-309?
##########
docs/layouts/shortcodes/generated/execution_checkpointing_configuration.html:
##########
@@ -30,7 +30,13 @@
<td><h5>execution.checkpointing.interval</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Duration</td>
- <td>Gets the interval in which checkpoints are periodically
scheduled.<br /><br />This setting defines the base interval. Checkpoint
triggering may be delayed by the settings <code
class="highlighter-rouge">execution.checkpointing.max-concurrent-checkpoints</code>
and <code
class="highlighter-rouge">execution.checkpointing.min-pause</code></td>
+ <td>Gets the interval in which checkpoints are periodically
scheduled.<br /><br />This setting defines the base interval. Checkpoint
triggering may be delayed by the settings <code
class="highlighter-rouge">execution.checkpointing.max-concurrent-checkpoints</code>,
<code class="highlighter-rouge">execution.checkpointing.min-pause</code> and
<code
class="highlighter-rouge">execution.checkpointing.interval-during-backlog</code></td>
+ </tr>
+ <tr>
+ <td><h5>execution.checkpointing.interval-during-backlog</h5></td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>Duration</td>
+ <td>Gets the interval in which checkpoints are periodically
scheduled when any source reports isProcessingBacklog=true.<br /><br
/>Checkpoint triggering may be delayed by the settings <code
class="highlighter-rouge">execution.checkpointing.max-concurrent-checkpoints</code>
and <code
class="highlighter-rouge">execution.checkpointing.min-pause</code></td>
Review Comment:
Should we use the same doc as specified in FLIP-309?
--
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]
