beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [beam] branch master updated (b7c2975 -> 38e3a81)
Date Wed, 19 Sep 2018 17:19:38 GMT
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


Mime
View raw message