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