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

Posted to commits@beam.apache.org by ch...@apache.org on 2021/08/18 17:49:21 UTC

[beam] branch master updated (bd51855 -> a0fbe00)

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

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


    from bd51855  [BEAM-12742] Samza Runner does not properly delete modified timer (#15322)
     add 17a2e3e  [BEAM-12740] [BEAM-8268] Improve error handling and retries for GCS rename operations
     add a0fbe00  Merge pull request #15301: [BEAM-12740] [BEAM-8268] Improve error handling and retries for GCS rename used by FileBasedSink

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/sdk/io/ClassLoaderFileSystem.java  |   5 +-
 .../java/org/apache/beam/sdk/io/FileBasedSink.java |   5 +-
 .../java/org/apache/beam/sdk/io/FileSystem.java    |   9 +-
 .../java/org/apache/beam/sdk/io/FileSystems.java   | 126 +++++------
 .../org/apache/beam/sdk/io/LocalFileSystem.java    |   9 +-
 .../sdk/extensions/gcp/storage/GcsFileSystem.java  |  25 ++-
 .../beam/sdk/extensions/gcp/util/GcsUtil.java      | 250 +++++++++++++++++----
 .../beam/sdk/extensions/gcp/util/GcsUtilTest.java  | 175 +++++++++++++--
 .../apache/beam/sdk/io/aws/s3/S3FileSystem.java    |   8 +-
 .../apache/beam/sdk/io/aws2/s3/S3FileSystem.java   |   8 +-
 .../azure/blobstore/AzureBlobStoreFileSystem.java  |   9 +-
 .../apache/beam/sdk/io/hdfs/HadoopFileSystem.java  |   8 +-
 12 files changed, 508 insertions(+), 129 deletions(-)