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/10/28 22:27:10 UTC

[beam] branch master updated (f6adc23 -> 0645404)

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

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


    from f6adc23  Merge pull request #9908 Increasing timeout due to still constant timeouts.
     add f89c1b9  [BEAM-8471] Flink native job submission for portable pipelines
     add 0645404  Merge pull request #9872: [BEAM-8471] Flink native job submission for portable pipelines

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/runners/flink/FlinkJobInvoker.java |   4 +-
 .../beam/runners/flink/FlinkJobServerDriver.java   |  38 +--
 .../flink/FlinkPortableClientEntryPoint.java       | 257 +++++++++++++++++++++
 .../runners/flink/FlinkJobServerDriverTest.java    |  14 +-
 .../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(+), 84 deletions(-)
 create mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPortableClientEntryPoint.java