[beam] branch master updated (d2f974c -> fa74467)

[ro...@apache.org]

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 d2f974c  Merge pull request #9802: [BEAM-8401] Upgrade to ZetaSQL 2019.10.1
     new 4f3bdb3  Implement ZipFile backed artifact service.
     new b3efb01  Make compatible with Java artifact services.
     new 5618350  [BEAM-8372] Job server submitting UberJars directly to Flink Runner.
     new b658172  Account for post BEAM-8183 file structure.
     new fa74467  Merge pull request #9775 from robertwb/easy-flink

The 23475 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/abstract_job_service.py    | 139 ++++++++++++
 .../runners/portability/artifact_service.py        | 195 ++++++++++++-----
 .../runners/portability/artifact_service_test.py   |  38 +++-
 .../runners/portability/flink_runner.py            |  10 +-
 .../portability/flink_uber_jar_job_server.py       | 238 +++++++++++++++++++++
 .../portability/flink_uber_jar_job_server_test.py  | 138 ++++++++++++
 .../runners/portability/local_job_service.py       | 163 +++++---------
 sdks/python/setup.py                               |   1 +
 8 files changed, 755 insertions(+), 167 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/portability/abstract_job_service.py
 create mode 100644 sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py
 create mode 100644 sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server_test.py