This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 06626dfc2a74e257a2d198e2c4a2dfde820e7706 Merge: b28fe91 dc1ccfa Author: Eugene Kirpichov <[email protected]> AuthorDate: Thu Jun 28 12:45:29 2018 -0700 Merge pull request #5803: Flink upload jobserver jar to flink remote environment Flink upload jobserver jar to flink remote environment .../flink/FlinkBatchPortablePipelineTranslator.java | 5 +++-- .../beam/runners/flink/FlinkExecutionEnvironments.java | 11 +++++------ .../apache/beam/runners/flink/FlinkJobInvocation.java | 17 +++++++++++------ .../org/apache/beam/runners/flink/FlinkJobInvoker.java | 8 +++++++- .../flink/FlinkPipelineExecutionEnvironment.java | 8 ++++++-- .../flink/FlinkStreamingPortablePipelineTranslator.java | 6 ++++-- 6 files changed, 36 insertions(+), 19 deletions(-)
