You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2021/04/15 16:05:32 UTC

[beam] branch master updated (97af077 -> 8e66956)

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

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


    from 97af077  [BEAM-9547] DataFrame.corr cleanup (#14327)
     add f9d4805  [BEAM-12091] Make file staging uniform among runners
     add 8e66956  Merge pull request #14520: [BEAM-12091] Make file staging uniform among runners

No new revisions were added by this update.

Summary of changes:
 .../construction/resources/PipelineResources.java  | 37 +++++++++-
 .../resources/PipelineResourcesTest.java           | 78 +++++++++++++++++++---
 .../flink/FlinkPipelineExecutionEnvironment.java   | 18 +----
 .../SparkStructuredStreamingRunner.java            | 20 +-----
 .../runners/spark/SparkCommonPipelineOptions.java  | 27 +-------
 .../beam/runners/spark/SparkPipelineRunner.java    |  8 ---
 .../org/apache/beam/runners/spark/SparkRunner.java | 18 +----
 .../beam/runners/twister2/Twister2Runner.java      | 33 +--------
 .../beam/sdk/util/common/ReflectHelpers.java       |  2 +-
 9 files changed, 114 insertions(+), 127 deletions(-)