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 2018/12/19 15:22:38 UTC

[beam] 01/01: Merge pull request #7296: [BEAM-6245] Add integration test for FlinkTransformOverrides

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

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

commit 85bd95e91a970bb5e6e2494b444a6b42f5e4acec
Merge: 66ff825 f67ac59
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Wed Dec 19 16:22:28 2018 +0100

    Merge pull request #7296: [BEAM-6245] Add integration test for FlinkTransformOverrides

 .../flink/FlinkPipelineExecutionEnvironment.java   | 11 ++--
 .../runners/flink/FlinkTransformOverrides.java     |  9 ++--
 ....java => PipelineTranslationModeOptimizer.java} | 26 +++------
 .../apache/beam/runners/flink/TranslationMode.java | 28 ----------
 .../FlinkPipelineExecutionEnvironmentTest.java     | 26 +++++++++
 .../PipelineTranslationModeOptimizerTest.java      | 63 ++++++++++++++++++++++
 6 files changed, 104 insertions(+), 59 deletions(-)