You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2020/05/07 18:02:30 UTC
[beam] branch asf-site updated: Publishing website 2020/05/07
18:02:17 at commit 6f09890
This is an automated email from the ASF dual-hosted git repository.
git-site-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/asf-site by this push:
new ec2a86c Publishing website 2020/05/07 18:02:17 at commit 6f09890
ec2a86c is described below
commit ec2a86cc46e16e60a774961157fd9afe91297419
Author: jenkins <bu...@apache.org>
AuthorDate: Thu May 7 18:02:17 2020 +0000
Publishing website 2020/05/07 18:02:17 at commit 6f09890
---
.../documentation/runners/flink/index.html | 22 ++++++++++++++++------
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/website/generated-content/documentation/runners/flink/index.html b/website/generated-content/documentation/runners/flink/index.html
index 6691abf..21c3035 100644
--- a/website/generated-content/documentation/runners/flink/index.html
+++ b/website/generated-content/documentation/runners/flink/index.html
@@ -718,6 +718,11 @@ which should be called before running the tests.
<td>Default: <code>-1</code></td>
</tr>
<tr>
+ <td><code>reportCheckpointDuration</code></td>
+ <td>If not null, reports the checkpoint duration of each ParDo stage in the provided metric namespace.</td>
+ <td></td>
+</tr>
+<tr>
<td><code>retainExternalizedCheckpointsOnCancellation</code></td>
<td>Sets the behavior of externalized checkpoints on cancellation.</td>
<td>Default: <code>false</code></td>
@@ -728,9 +733,9 @@ which should be called before running the tests.
<td></td>
</tr>
<tr>
- <td><code>shutdownSourcesOnFinalWatermark</code></td>
- <td>If set, shutdown sources when their watermark reaches +Inf.</td>
- <td>Default: <code>false</code></td>
+ <td><code>shutdownSourcesAfterIdleMs</code></td>
+ <td>Shuts down sources which have been idle for the configured time of milliseconds. Once a source has been shut down, checkpointing is not possible anymore. Shutting down the sources eventually leads to pipeline shutdown (=Flink job finishes) once all input has been processed. Unless explicitly set, this will default to Long.MAX_VALUE when checkpointing is enabled and to 0 when checkpointing is disabled. See https://issues.apache.org/jira/browse/FLINK-2491 for progress on this issue.</td>
+ <td>Default: <code>-1</code></td>
</tr>
<tr>
<td><code>stateBackendFactory</code></td>
@@ -872,6 +877,11 @@ which should be called before running the tests.
<td>Default: <code>-1</code></td>
</tr>
<tr>
+ <td><code>report_checkpoint_duration</code></td>
+ <td>If not null, reports the checkpoint duration of each ParDo stage in the provided metric namespace.</td>
+ <td></td>
+</tr>
+<tr>
<td><code>retain_externalized_checkpoints_on_cancellation</code></td>
<td>Sets the behavior of externalized checkpoints on cancellation.</td>
<td>Default: <code>false</code></td>
@@ -882,9 +892,9 @@ which should be called before running the tests.
<td></td>
</tr>
<tr>
- <td><code>shutdown_sources_on_final_watermark</code></td>
- <td>If set, shutdown sources when their watermark reaches +Inf.</td>
- <td>Default: <code>false</code></td>
+ <td><code>shutdown_sources_after_idle_ms</code></td>
+ <td>Shuts down sources which have been idle for the configured time of milliseconds. Once a source has been shut down, checkpointing is not possible anymore. Shutting down the sources eventually leads to pipeline shutdown (=Flink job finishes) once all input has been processed. Unless explicitly set, this will default to Long.MAX_VALUE when checkpointing is enabled and to 0 when checkpointing is disabled. See https://issues.apache.org/jira/browse/FLINK-2491 for progress on this issue.</td>
+ <td>Default: <code>-1</code></td>
</tr>
<tr>
<td><code>state_backend_factory</code></td>