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 2019/10/02 14:06:20 UTC

[beam] branch master updated (652ed87 -> 6551d09)

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 652ed87  Merge pull request #9710: Fix broken :runners:java-fn-execution:spotbugsMain task
     add 85090ab  [BEAM-8303] Ensure FileSystems registration code runs in non UDF Flink operators
     add 6551d09  Merge pull request #9688: [BEAM-8303] Ensure FileSystems registration code runs in non UDF Flink operators

No new revisions were added by this update.

Summary of changes:
 .../FlinkBatchPortablePipelineTranslator.java      |  3 +-
 .../flink/FlinkBatchTransformTranslators.java      |  2 +-
 .../FlinkStreamingPortablePipelineTranslator.java  | 35 ++++++++--
 .../flink/FlinkStreamingTransformTranslators.java  | 79 +++++++++++++++++++---
 .../translation/functions/FlinkDoFnFunction.java   |  7 +-
 .../functions/FlinkExecutableStageFunction.java    | 10 ++-
 .../FlinkExecutableStagePruningFunction.java       | 19 +++++-
 .../FlinkMergingNonShuffleReduceFunction.java      |  9 +++
 .../functions/FlinkMultiOutputPruningFunction.java | 18 ++++-
 .../functions/FlinkPartialReduceFunction.java      |  9 +++
 .../translation/functions/FlinkReduceFunction.java |  9 +++
 .../functions/FlinkStatefulDoFnFunction.java       |  7 +-
 .../wrappers/streaming/DoFnOperator.java           |  3 +-
 .../wrappers/streaming/io/DedupingOperator.java    | 15 ++++
 .../streaming/io/UnboundedSourceWrapper.java       |  2 +
 .../FlinkExecutableStageFunctionTest.java          |  9 ++-
 .../wrappers/streaming/DedupingOperatorTest.java   |  3 +-
 17 files changed, 206 insertions(+), 33 deletions(-)