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/11/28 00:55:44 UTC

[beam] 01/01: Merge pull request #7031: [BEAM-6058] Adding option for Flink configuration directory and setting config in execution environment

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 c2aaf2d613f25df1754d67f61d29d7124ac06b50
Merge: 02c763b f84feac
Author: Thomas Weise <tw...@users.noreply.github.com>
AuthorDate: Tue Nov 27 16:55:37 2018 -0800

    Merge pull request #7031: [BEAM-6058] Adding option for Flink configuration directory and setting config in execution environment

 runners/flink/job-server/build.gradle              |  2 ++
 .../FlinkBatchPortablePipelineTranslator.java      | 11 ++++++--
 .../runners/flink/FlinkExecutionEnvironments.java  | 32 ++++++++++++----------
 .../beam/runners/flink/FlinkJobInvocation.java     | 10 +++++--
 .../apache/beam/runners/flink/FlinkJobInvoker.java |  1 +
 .../beam/runners/flink/FlinkJobServerDriver.java   | 15 ++++++++++
 .../FlinkStreamingPortablePipelineTranslator.java  |  8 ++++--
 .../flink/FlinkExecutionEnvironmentsTest.java      |  4 +--
 .../beam/runners/flink/PortableExecutionTest.java  |  1 +
 .../runners/flink/PortableStateExecutionTest.java  |  1 +
 .../runners/flink/PortableTimersExecutionTest.java |  1 +
 11 files changed, 61 insertions(+), 25 deletions(-)