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 <bui...@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>