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 2019/11/18 17:29:29 UTC

[beam] 01/01: Merge pull request #10139: [BEAM-8471] Flink native job submission for portable pipelines

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

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

commit 60da80c4daa7221c025065abb182b9fa6ac2f3e0
Merge: bd744a3 16e85b0
Author: Thomas Weise <tw...@users.noreply.github.com>
AuthorDate: Mon Nov 18 09:29:18 2019 -0800

    Merge pull request #10139: [BEAM-8471] Flink native job submission for portable pipelines

 .../apache/beam/runners/flink/FlinkJobInvoker.java |   4 +-
 .../beam/runners/flink/FlinkJobServerDriver.java   |  39 ++--
 .../flink/FlinkPortableClientEntryPoint.java       | 257 +++++++++++++++++++++
 .../runners/flink/FlinkJobServerDriverTest.java    |   9 +-
 .../beam/runners/flink/FlinkSavepointTest.java     |  15 +-
 .../beam/runners/flink/PortableExecutionTest.java  |  17 +-
 .../runners/flink/PortableStateExecutionTest.java  |  17 +-
 .../runners/flink/PortableTimersExecutionTest.java |  17 +-
 .../beam/runners/flink/ReadSourcePortableTest.java |  17 +-
 .../fnexecution/environment/ProcessManager.java    |  39 +++-
 .../fnexecution/jobsubmission/JobServerDriver.java |  16 +-
 .../environment/ProcessManagerTest.java            |  58 +++++
 .../beam/runners/spark/SparkJobServerDriver.java   |  12 +-
 13 files changed, 437 insertions(+), 80 deletions(-)