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 17:47:22 UTC

[beam] branch release-2.16.0 updated (de30361 -> 819a242)

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

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


    from de30361  Merge pull request #9696 [BEAM-8324] Restrict the upper bound for dill due to incompatibility between versions 0.3.0 and 0.3.1.1.
     add 10e49947e [BEAM-8303] Ensure FileSystems registration code runs in non UDF Flink operators
     add 819a242  Merge pull request #9711: [release-2.16.0][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(-)