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 <[email protected]> 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(-)
