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
