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 2019/01/31 10:45:11 UTC
[beam] branch asf-site updated: Publishing website 2019/01/31
10:45:06 at commit 42d0918
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 9f0ce2d Publishing website 2019/01/31 10:45:06 at commit 42d0918
9f0ce2d is described below
commit 9f0ce2d4021cc5932ea08b673639a5bdbffcaa8e
Author: jenkins <bu...@apache.org>
AuthorDate: Thu Jan 31 10:45:06 2019 +0000
Publishing website 2019/01/31 10:45:06 at commit 42d0918
---
website/generated-content/documentation/runners/flink/index.html | 3 +++
1 file changed, 3 insertions(+)
diff --git a/website/generated-content/documentation/runners/flink/index.html b/website/generated-content/documentation/runners/flink/index.html
index 0936d64..b49f1a3 100644
--- a/website/generated-content/documentation/runners/flink/index.html
+++ b/website/generated-content/documentation/runners/flink/index.html
@@ -375,6 +375,9 @@ period.</p>
<p>If your pipeline uses an unbounded data source or sink, the Flink Runner will automatically switch to streaming mode. You can enforce streaming mode by using the <code class="highlighter-rouge">streaming</code> setting mentioned below.</p>
+<p>Note: The Runner will print a warning message when unbounded sources are used and checkpointing is not enabled.
+Many sources like <code class="highlighter-rouge">PubSubIO</code> rely on their checkpoints to be acknowledged which can only be done when checkpointing is enabled for the <code class="highlighter-rouge">FlinkRunner</code>. To enable checkpointing, please set <span class="language-java"><code class="highlighter-rouge">checkpointingInterval</code></span><span class="language-py"><code class="highlighter-rouge">checkpointing_interval</code></span> to the desired checkpointing interval in m [...]
+
<h2 id="pipeline-options-for-the-flink-runner">Pipeline options for the Flink Runner</h2>
<p>When executing your pipeline with the Flink Runner, you can set these pipeline options.</p>