You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2018/12/17 15:19:58 UTC

[beam] branch master updated (4588c25 -> a68f209)

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 4588c25  Merge pull request #7285: [BEAM-6235] Upgrade AutoValue to version 1.6.3
     add 89ad88d  [BEAM-2873] Setting number of shards for writes with runner determined sharding
     add a68f209  Merge pull request #4760: [BEAM-2873] Setting number of shards for writes with runner determined sharding

No new revisions were added by this update.

Summary of changes:
 .../flink/FlinkPipelineExecutionEnvironment.java   |  10 +-
 .../flink/FlinkStreamingPipelineTranslator.java    |  70 +++++++++++++
 .../runners/flink/FlinkTransformOverrides.java     |  19 +++-
 .../runners/flink/FlinkTransformOverridesTest.java | 116 +++++++++++++++++++++
 4 files changed, 205 insertions(+), 10 deletions(-)
 create mode 100644 runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkTransformOverridesTest.java