You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by mx...@apache.org on 2019/10/31 16:27:08 UTC
[beam] 01/01: Merge pull request #9938: [BEAM-8507] Augment
'flink_master' pipeline option for Python FlinkRunner (#9918)
This is an automated email from the ASF dual-hosted git repository.
mxm pushed a commit to branch release-2.17.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 91bbff1767a229f3f1b0359029312bbc01b54426
Merge: 76b8009 565ec74
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Thu Oct 31 17:26:58 2019 +0100
Merge pull request #9938: [BEAM-8507] Augment 'flink_master' pipeline option for Python FlinkRunner (#9918)
.../runners/flink/FlinkExecutionEnvironments.java | 24 ++++++++++----
.../flink/FlinkExecutionEnvironmentsTest.java | 38 +++++++++++++++++++++-
.../runners/portability/flink_runner.py | 35 ++++++++++++++++----
.../runners/portability/portable_runner.py | 5 +++
4 files changed, 89 insertions(+), 13 deletions(-)