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 4fcf634 Publishing website 2021/04/09 06:03:01 at commit f49e097 4fcf634 is described below commit 4fcf634ccd2c6f7062484c3a17cbb4a8c984341e Author: jenkins <bui...@apache.org> AuthorDate: Fri Apr 9 06:03:01 2021 +0000 Publishing website 2021/04/09 06:03:01 at commit f49e097 --- .../documentation/runners/flink/index.html | 14 +++++++------- website/generated-content/sitemap.xml | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/website/generated-content/documentation/runners/flink/index.html b/website/generated-content/documentation/runners/flink/index.html index 8a83609..a3c08b4 100644 --- a/website/generated-content/documentation/runners/flink/index.html +++ b/website/generated-content/documentation/runners/flink/index.html @@ -75,9 +75,9 @@ one could run:</p><div class="language-py snippet"><div class="notebook-skip cod <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></div><p class=language-py>To run on an embedded Flink cluster, simply omit the <code>flink_master</code> option and an embedded Flink cluster will be automatically started and shut down for the job.</p><p class=language-py>The optional <code>flink_version</code> option may be required as well for older versions of Python.</p><p class=language-portable>Starting with Beam 2.18.0, pre-built Flink Job Service Docker images are available at Docker Hub: -<a href=https://hub.docker.com/r/apache/beam_flink1.8_job_server>Flink 1.8</a>, -<a href=https://hub.docker.com/r/apache/beam_flink1.9_job_server>Flink 1.9</a>. -<a href=https://hub.docker.com/r/apache/beam_flink1.10_job_server>Flink 1.10</a>.</p><p class=language-portable>To run a pipeline on an embedded Flink cluster:</p><p class=language-portable>(1) Start the JobService endpoint: <code>docker run --net=host apache/beam_flink1.10_job_server:latest</code></p><p class=language-portable>The JobService is the central instance where you submit your Beam pipeline to. +<a href=https://hub.docker.com/r/apache/beam_flink1.10_job_server>Flink 1.10</a>, +<a href=https://hub.docker.com/r/apache/beam_flink1.11_job_server>Flink 1.11</a>, +<a href=https://hub.docker.com/r/apache/beam_flink1.12_job_server>Flink 1.12</a>.</p><p class=language-portable>To run a pipeline on an embedded Flink cluster:</p><p class=language-portable>(1) Start the JobService endpoint: <code>docker run --net=host apache/beam_flink1.10_job_server:latest</code></p><p class=language-portable>The JobService is the central instance where you submit your Beam pipeline to. The JobService will create a Flink job for the pipeline and execute the job.</p><p class=language-portable>(2) Submit the Python pipeline to the above endpoint by using the <code>PortableRunner</code>, <code>job_endpoint</code> set to <code>localhost:8099</code> (this is the default address of the JobService). Optionally set <code>environment_type</code> set to <code>LOOPBACK</code>. For example:</p><div class="language-portable snippet"><div class="notebook-skip code-snippet"><a class=copy type=button data-bs-toggle=tooltip data-bs-placement=bottom title="Copy to clipboard"><img src=/images/copy-icon.svg></a><pre><code class=language-portable data-lang=portable>import apache_beam as beam from apache_beam.options.pipeline_options import PipelineOptions @@ -105,14 +105,14 @@ Many sources like <code>PubSubIO</code> rely on their checkpoints to be acknowle reference class:</p><div class=language-java><table class="table table-bordered"><tr><td><code>allowNonRestoredState</code></td><td>Flag indicating whether non restored state is allowed if the savepoint contains state for an operator that is no longer part of the pipeline.</td><td>Default: <code>false</code></td></tr><tr><td><code>autoBalanceWriteFilesShardingEnabled</code></td><td>Flag indicating whether auto-balance sharding for WriteFiles transform should be enabled. This might prove [...] <a href=https://beam.apache.org/releases/javadoc/2.28.0/index.html?org/apache/beam/sdk/options/PipelineOptions.html>PipelineOptions</a> reference.</p><h2 id=flink-version-compatibility>Flink Version Compatibility</h2><p>The Flink cluster version has to match the minor version used by the FlinkRunner. -The minor version is the first two numbers in the version string, e.g. in <code>1.8.0</code> the -minor version is <code>1.8</code>.</p><p>We try to track the latest version of Apache Flink at the time of the Beam release. +The minor version is the first two numbers in the version string, e.g. in <code>1.12.0</code> the +minor version is <code>1.12</code>.</p><p>We try to track the latest version of Apache Flink at the time of the Beam release. A Flink version is supported by Beam for the time it is supported by the Flink community. The Flink community supports the last two minor versions. When support for a Flink version is dropped, it may be deprecated and removed also from Beam. -To find out which version of Flink is compatible with Beam please see the table below:</p><table class="table table-bordered"><tr><th>Beam Version</th><th>Flink Version</th><th>Artifact Id</th></tr><tr><td rowspan=5>≥ 2.27.0</td><td>1.12.x <sup>*</sup></td><td>beam-runners-flink-1.12</td></tr><tr><td>1.11.x <sup>*</sup></td><td>beam-runners-flink-1.11</td></tr><tr><td>1.10.x</td><td>beam-runners-flink-1.10</td></tr><tr><td>1.9.x</td><td>beam-runners-flink-1.9</td></tr><tr><td>1.8.x</t [...] +To find out which version of Flink is compatible with Beam please see the table below:</p><table class="table table-bordered"><tr><th>Beam Version</th><th>Flink Version</th><th>Artifact Id</th></tr><tr><td rowspan=3>≥ 2.30.0</td><td>1.12.x <sup>*</sup></td><td>beam-runners-flink-1.12</td></tr><tr><td>1.11.x <sup>*</sup></td><td>beam-runners-flink-1.11</td></tr><tr><td>1.10.x</td><td>beam-runners-flink-1.10</td></tr><tr><td rowspan=5>2.27.0 - 2.29.0</td><td>1.12.x <sup>*</sup></td><td> [...] capabilities of the classic Flink Runner.</p><p>The <a href=https://s.apache.org/apache-beam-portability-support-table>Portable Capability Matrix</a> documents -the capabilities of the portable Flink Runner.</p><div class=feedback><p class=update>Last updated on 2020/12/28</p><h3>Have you found everything you were looking for?</h3><p class=description>Was it all useful and clear? Is there anything that you would like to change? Let us know!</p><button class=load-button><a href="mailto:d...@beam.apache.org?subject=Beam Website Feedback">SEND FEEDBACK</a></button></div></div></div><footer class=footer><div class=footer__contained><div class=footer_ [...] +the capabilities of the portable Flink Runner.</p><div class=feedback><p class=update>Last updated on 2021/03/12</p><h3>Have you found everything you were looking for?</h3><p class=description>Was it all useful and clear? Is there anything that you would like to change? Let us know!</p><button class=load-button><a href="mailto:d...@beam.apache.org?subject=Beam Website Feedback">SEND FEEDBACK</a></button></div></div></div><footer class=footer><div class=footer__contained><div class=footer_ [...] <a href=http://www.apache.org>The Apache Software Foundation</a> | <a href=/privacy_policy>Privacy Policy</a> | <a href=/feed.xml>RSS Feed</a><br><br>Apache Beam, Apache, Beam, the Beam logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation. All other products or name brands are trademarks of their respective holders, including The Apache Software Foundation.</div></div></div></div></footer></body></html> \ No newline at end of file diff --git a/website/generated-content/sitemap.xml b/website/generated-content/sitemap.xml index 4d2f432..d406ed6 100644 --- a/website/generated-content/sitemap.xml +++ b/website/generated-content/sitemap.xml @@ -1 +1 @@ -<?xml version="1.0" encoding="utf-8" standalone="yes"?><urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9" xmlns:xhtml="http://www.w3.org/1999/xhtml"><url><loc>/blog/beam-2.28.0/</loc><lastmod>2021-02-22T11:40:20-08:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/blog/k [...] \ No newline at end of file +<?xml version="1.0" encoding="utf-8" standalone="yes"?><urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9" xmlns:xhtml="http://www.w3.org/1999/xhtml"><url><loc>/blog/beam-2.28.0/</loc><lastmod>2021-02-22T11:40:20-08:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-03-31T21:00:41-04:00</lastmod></url><url><loc>/blog/k [...] \ No newline at end of file