This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 6f479135187 [hotfix] Improve
execution.checkpointing.unaligned.interruptible-timers.enabled documentation
6f479135187 is described below
commit 6f479135187c03b15cb91d2980bfca5d25492342
Author: Piotr Nowojski <[email protected]>
AuthorDate: Wed Jun 12 14:27:19 2024 +0200
[hotfix] Improve
execution.checkpointing.unaligned.interruptible-timers.enabled documentation
---
docs/layouts/shortcodes/generated/checkpointing_configuration.html | 2 +-
.../java/org/apache/flink/configuration/CheckpointingOptions.java | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/docs/layouts/shortcodes/generated/checkpointing_configuration.html
b/docs/layouts/shortcodes/generated/checkpointing_configuration.html
index 5fbf346b114..a087b98bb13 100644
--- a/docs/layouts/shortcodes/generated/checkpointing_configuration.html
+++ b/docs/layouts/shortcodes/generated/checkpointing_configuration.html
@@ -174,7 +174,7 @@
<td><h5>execution.checkpointing.unaligned.interruptible-timers.enabled</h5></td>
<td style="word-wrap: break-word;">false</td>
<td>Boolean</td>
- <td>Allows unaligned checkpoints to skip timers that are currently
being fired.</td>
+ <td>Allows unaligned checkpoints to skip timers that are currently
being fired. For this feature to be enabled, it must be also supported by the
operator. Currently this is supported by all TableStreamOperators and
CepOperator.</td>
</tr>
<tr>
<td><h5>execution.checkpointing.unaligned.max-subtasks-per-channel-state-file</h5></td>
diff --git
a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
index 4bb30c1c563..c9180f762cd 100644
---
a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
+++
b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
@@ -649,7 +649,9 @@ public class CheckpointingOptions {
.booleanType()
.defaultValue(false)
.withDescription(
- "Allows unaligned checkpoints to skip timers that
are currently being fired.");
+ "Allows unaligned checkpoints to skip timers that
are currently being fired."
+ + " For this feature to be enabled, it
must be also supported by the operator."
+ + " Currently this is supported by all
TableStreamOperators and CepOperator.");
public static final ConfigOption<Boolean>
ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH =
ConfigOptions.key("execution.checkpointing.checkpoints-after-tasks-finish")
