You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2018/08/24 18:23:35 UTC

[beam] 01/01: Merge pull request #6265: [BEAM-4130] Bring up Job Server container for Python jobs

This is an automated email from the ASF dual-hosted git repository.

thw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 96d2887f3d807d3546339eb83749feadc02dcd9c
Merge: f9d3f55 5b3b9e0
Author: Thomas Weise <tw...@users.noreply.github.com>
AuthorDate: Fri Aug 24 11:23:29 2018 -0700

    Merge pull request #6265: [BEAM-4130] Bring up Job Server container for Python jobs

 runners/flink/job-server-container/Dockerfile      |   2 +-
 runners/flink/job-server-container/build.gradle    |   2 +-
 runners/flink/job-server/build.gradle              |   2 +-
 .../beam/runners/flink/FlinkJobServerDriver.java   |  50 +++++++---
 .../beam/runners/fnexecution/ServerFactory.java    |  21 ++++-
 .../control/DockerJobBundleFactory.java            |  22 ++++-
 .../environment/DockerEnvironmentFactory.java      |   2 +
 .../runners/portability/flink_runner_test.py       |   3 +-
 .../apache_beam/runners/portability/job_server.py  | 101 +++++++++++++++++++++
 .../runners/portability/portable_runner.py         |  33 +++++--
 sdks/python/build.gradle                           |  18 +++-
 11 files changed, 224 insertions(+), 32 deletions(-)