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(-)
