This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 281b8e7 [FLINK-26555][runtime] Adds closing and flushing to
OutputStream
add 4907f5f [FLINK-26484][fs] Introduces Presto-specific FileSystem
implementation that handles the recursive deletion
No new revisions were added by this update.
Summary of changes:
.../flink/core/fs/FileSystemBehaviorTestSuite.java | 95 +++++++++++++-
.../fs/s3/common/AbstractS3FileSystemFactory.java | 20 ++-
.../flink/fs/s3presto/FlinkS3PrestoFileSystem.java | 140 +++++++++++++++++++++
.../flink/fs/s3presto/S3FileSystemFactory.java | 19 +++
4 files changed, 271 insertions(+), 3 deletions(-)
create mode 100644
flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java