This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 35c30fe Merge pull request #9105: [BEAM-7784] Fixup for Guava upgrade
add 648277a Refactor portable JobService to allow better sharing of code.
add b05554b Simplify known runner parsing code.
add e8a2de8 [BEAM-7722] Add a Python FlinkRunner that fetches and uses
released artifacts.
add c5f4334 Pull out generic java job server helpers from flink.
new 9589835 Merge pull request #9043 [BEAM-7722] Python FlinkRunner
fetching released artifacts.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runners/portability/flink_runner.py | 69 +++++
.../apache_beam/runners/portability/job_server.py | 290 ++++++++++++++++-----
.../runners/portability/portable_runner.py | 46 ++--
sdks/python/apache_beam/runners/runner.py | 64 ++---
website/src/documentation/runners/flink.md | 23 +-
5 files changed, 363 insertions(+), 129 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/portability/flink_runner.py
