This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from b7c2975 Merge pull request #5841: [BEAM-3446] Fixes RedisIO non-prefix read operations add 8f94a03 [BEAM-3089] Use Flink cluster parallelism if no parallelism provided add 33ac2b0 [flink] Revert default checkpointing mode to EXACTLY_ONCE add 9ea1120 [flink] Use default value for checkpoint timeout add 3f75e89 [flink] Set default master url to [auto] add 7444755 [BEAM-3089] Test default values of FlinkPipelineOptions new 38e3a81 Merge pull request #6426: [BEAM-3089] Fix default values in FlinkPipelineOptions / Add tests The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../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(-) delete mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/DefaultParallelismFactory.java create mode 100644 runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkExecutionEnvironmentsTest.java create mode 100644 runners/flink/src/test/resources/flink-conf.yaml