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 38e3a8101a4c2269010fa2544be0acef5e740368 Merge: b7c2975 7444755 Author: Thomas Weise <twe...@users.noreply.github.com> AuthorDate: Wed Sep 19 10:19:31 2018 -0700 Merge pull request #6426: [BEAM-3089] Fix default values in FlinkPipelineOptions / Add tests .../runners/flink/DefaultParallelismFactory.java | 39 ----- .../runners/flink/FlinkExecutionEnvironments.java | 76 ++++++++-- .../apache/beam/runners/flink/FlinkJobInvoker.java | 5 +- .../beam/runners/flink/FlinkPipelineOptions.java | 11 +- .../org/apache/beam/runners/flink/FlinkRunner.java | 5 - .../flink/FlinkExecutionEnvironmentsTest.java | 162 +++++++++++++++++++++ .../beam/runners/flink/PipelineOptionsTest.java | 27 ++++ .../flink/streaming/GroupByNullKeyTest.java | 2 + runners/flink/src/test/resources/flink-conf.yaml | 19 +++ 9 files changed, 285 insertions(+), 61 deletions(-)