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/11/28 14:08:02 UTC
[beam] branch asf-site updated: Publishing website 2019/11/28
14:07:55 at commit e68445c
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 bb6bc38 Publishing website 2019/11/28 14:07:55 at commit e68445c
bb6bc38 is described below
commit bb6bc38250ca6593f3f71f79417794a90603c100
Author: jenkins <bu...@apache.org>
AuthorDate: Thu Nov 28 14:07:56 2019 +0000
Publishing website 2019/11/28 14:07:55 at commit e68445c
---
website/generated-content/documentation/runners/flink/index.html | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/website/generated-content/documentation/runners/flink/index.html b/website/generated-content/documentation/runners/flink/index.html
index 67d39e0..f27a1df 100644
--- a/website/generated-content/documentation/runners/flink/index.html
+++ b/website/generated-content/documentation/runners/flink/index.html
@@ -534,8 +534,8 @@ Note however that <code class="highlighter-rouge">environment_type=LOOPBACK</cod
See <a href="/roadmap/portability/#sdk-harness-config">here</a> for details.
</span></p>
-<p><span class="language-py">As of Beam 2.15.0, steps 2 and 3 can be automated in Python by using the <code class="highlighter-rouge">FlinkRunner</code>,
-plus the optional <code class="highlighter-rouge">flink_version</code> and <code class="highlighter-rouge">flink_master_url</code> options if required, i.e.
+<p><span class="language-py">Steps 2 and 3 can be automated in Python by using the <code class="highlighter-rouge">FlinkRunner</code>,
+plus the optional <code class="highlighter-rouge">flink_version</code> and <code class="highlighter-rouge">flink_master</code>* options, e.g.:
</span></p>
<div class="language-py highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kn">import</span> <span class="nn">apache_beam</span> <span class="k">as</span> <span class="n">beam</span>
@@ -544,13 +544,15 @@ plus the optional <code class="highlighter-rouge">flink_version</code> and <code
<span class="n">options</span> <span class="o">=</span> <span class="n">PipelineOptions</span><span class="p">([</span>
<span class="s">"--runner=FlinkRunner"</span><span class="p">,</span>
<span class="s">"--flink_version=1.8"</span><span class="p">,</span>
- <span class="s">"--flink_master_url=localhost:8081"</span><span class="p">,</span>
+ <span class="s">"--flink_master=localhost:8081"</span><span class="p">,</span>
<span class="s">"--environment_type=LOOPBACK"</span>
<span class="p">])</span>
<span class="k">with</span> <span class="n">beam</span><span class="o">.</span><span class="n">Pipeline</span><span class="p">(</span><span class="n">options</span><span class="p">)</span> <span class="k">as</span> <span class="n">p</span><span class="p">:</span>
<span class="o">...</span>
</code></pre></div></div>
+<p>* Note: For Beam versions < 2.17.0, use <code class="highlighter-rouge">flink_master_url</code> instead of <code class="highlighter-rouge">flink_master</code>.</p>
+
<h2 id="additional-information-and-caveats">Additional information and caveats</h2>
<h3 id="monitoring-your-job">Monitoring your job</h3>