This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4faf0966766 [FLINK-35482][parquet][test] Fix timezone handling in
ParquetInt64TimestampReaderTest
add 9b674157023 [FLINK-35770][s3] Make s5cmd copyFiles interruptable
through CloseableRegistry to improve job cancellation behavior during restore.
add 576b30820ff [FLINK-36108][s3] Wait for state download on cancellation
to enforce cleanup
add 0daca7b6db8 [FLINK-35771][s3] Limit the amount of work per s5cmd call
No new revisions were added by this update.
Summary of changes:
.../flink/core/fs/PathsCopyingFileSystem.java | 10 +-
.../fs/s3/common/AbstractS3FileSystemFactory.java | 13 ++
.../flink/fs/s3/common/FlinkS3FileSystem.java | 55 +++++-
.../flink/fs/s3/common/FlinkS3FileSystemTest.java | 188 ++++++++++++++++++++
.../flink/fs/s3/common/S3EntropyFsFactoryTest.java | 49 +-----
.../fs/s3/common/TestS3FileSystemFactory.java | 66 +++++++
.../state/filesystem/FsCheckpointStateToolset.java | 4 +-
.../state/RocksDBStateDataTransferHelper.java | 6 +-
.../streaming/state/RocksDBStateDownloader.java | 26 ++-
.../state/RocksDBStateDownloaderTest.java | 190 ++++++++++++++++++++-
tools/maven/suppressions.xml | 2 +-
11 files changed, 547 insertions(+), 62 deletions(-)
create mode 100644
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/FlinkS3FileSystemTest.java
create mode 100644
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/TestS3FileSystemFactory.java
