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 b63a62b Publishing website 2021/05/28 18:01:38 at commit 00eb420 b63a62b is described below commit b63a62bc83305217151597c4017587067a86f580 Author: jenkins <bui...@apache.org> AuthorDate: Fri May 28 18:01:39 2021 +0000 Publishing website 2021/05/28 18:01:38 at commit 00eb420 --- .../generated-content/documentation/runners/flink/index.html | 11 ++++++----- website/generated-content/sitemap.xml | 2 +- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/website/generated-content/documentation/runners/flink/index.html b/website/generated-content/documentation/runners/flink/index.html index 5976854..17e528c 100644 --- a/website/generated-content/documentation/runners/flink/index.html +++ b/website/generated-content/documentation/runners/flink/index.html @@ -77,7 +77,8 @@ one could run:</p><div class="language-py snippet"><div class="notebook-skip cod 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.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. +<a href=https://hub.docker.com/r/apache/beam_flink1.12_job_server>Flink 1.12</a>. +<a href=https://hub.docker.com/r/apache/beam_flink1.13_job_server>Flink 1.13</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 +106,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.29.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.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. +The minor version is the first two numbers in the version string, e.g. in <code>1.13.0</code> the +minor version is <code>1.13</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=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> [...] +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=4>≥ 2.31.0</td><td>1.13.x <sup>*</sup></td><td>beam-runners-flink-1.13</td></tr><tr><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>< [...] 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 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_ [...] +the capabilities of the portable Flink Runner.</p><div class=feedback><p class=update>Last updated on 2021/05/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 a82e1c6..53a5b5d 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.29.0/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-05-25T17:22:37-07:00</lastmod></url><url><loc>/blog/b [...] \ 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.29.0/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-04-15T20:51:50-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-05-25T17:22:37-07:00</lastmod></url><url><loc>/blog/b [...] \ No newline at end of file