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 a289a7c Publishing website 2019/12/21 06:23:33 at commit 76a0fcf
a289a7c is described below
commit a289a7c24443f8dccce8f6ed32f40d17eb55a40a
Author: jenkins <bui...@apache.org>
AuthorDate: Sat Dec 21 06:23:34 2019 +0000
Publishing website 2019/12/21 06:23:33 at commit 76a0fcf
---
.../generated-content/documentation/runners/flink/index.html | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/website/generated-content/documentation/runners/flink/index.html
b/website/generated-content/documentation/runners/flink/index.html
index eab90fe..029e79b 100644
--- a/website/generated-content/documentation/runners/flink/index.html
+++ b/website/generated-content/documentation/runners/flink/index.html
@@ -561,7 +561,7 @@ plus the optional <code
class="highlighter-rouge">flink_version</code> and <code
<h3 id="streaming-execution">Streaming Execution</h3>
-<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>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> flag.</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 [...]
@@ -570,11 +570,9 @@ Many sources like <code
class="highlighter-rouge">PubSubIO</code> rely on their
<p>When executing your pipeline with the Flink Runner, you can set these
pipeline options.</p>
-<p>See the reference documentation for the<span class="language-java">
+<p>The following list of Flink-specific pipeline options is generated
automatically from the
<a
href="https://beam.apache.org/releases/javadoc/2.16.0/index.html?org/apache/beam/runners/flink/FlinkPipelineOptions.html";>FlinkPipelineOptions</a>
-</span><span class="language-py">
-<a
href="https://github.com/apache/beam/blob/master/sdks/python/apache_beam/options/pipeline_options.py";>PipelineOptions</a>
-</span>interface (and its subinterfaces) for the complete list of pipeline
configuration options.</p>
+reference class:</p>
<!-- Java Options -->
<div class="language-java">
@@ -885,6 +883,10 @@ which should be called before running the tests.
</div>
+<p>For general Beam pipeline options see the
+<a
href="https://beam.apache.org/releases/javadoc/2.16.0/index.html?org/apache/beam/sdk/options/PipelineOptions.html";>PipelineOptions</a>
+reference.</p>
+
<h2 id="capability">Capability</h2>
<p>The <a href="/documentation/runners/capability-matrix/">Beam Capability
Matrix</a> documents the
