This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d31471e [FLINK-25404] Introduce borrowed and owned storage directory
to BlobServer/Cache for better clean up
add 154ee77 [hotfix] Update TestingBlobStoreBuilder to use TriFunction
add 5295d4a [hotfix] Remove mocking from BlobServerPutTest
add 5233f01 [hotfix] Remove mocking from BlobServerGetTest
add ab264e4 [hotfix] Refactor BlobServer.getFileInternal to not take
expected blob file
add 85efe24 [hotfix] Speed up BlobClientTest by removing 10s sleep
add f2c206b [hotfix] Simplify TransientBlobCleanupTask to not rely on
internal BlobServer details
add 137a03f [FLINK-25405] Let BlobServer check and delete corrupted blobs
at start up
add ea52732 [FLINK-25405] Let AbstractBlobCache check for corrupted blobs
at start up
No new revisions were added by this update.
Summary of changes:
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 2 +-
.../java/org/apache/flink/hdfstests/HDFSTest.java | 7 +-
.../flink/runtime/blob/AbstractBlobCache.java | 11 +-
.../flink/runtime/blob/BlobCacheService.java | 6 +-
.../org/apache/flink/runtime/blob/BlobKey.java | 62 +++++++--
.../org/apache/flink/runtime/blob/BlobServer.java | 36 +++---
.../flink/runtime/blob/BlobServerConnection.java | 5 +-
.../org/apache/flink/runtime/blob/BlobUtils.java | 87 +++++++++++++
.../flink/runtime/blob/PermanentBlobCache.java | 12 +-
.../flink/runtime/blob/TransientBlobCache.java | 9 +-
.../runtime/blob/TransientBlobCleanupTask.java | 51 ++------
.../runtime/blob/BlobCacheCorruptionTest.java | 37 ++----
.../flink/runtime/blob/BlobCacheDeleteTest.java | 1 +
.../flink/runtime/blob/BlobClientSslTest.java | 7 +-
.../apache/flink/runtime/blob/BlobClientTest.java | 35 ++---
.../org/apache/flink/runtime/blob/BlobKeyTest.java | 32 +++++
.../runtime/blob/BlobServerCorruptionTest.java | 24 +---
.../flink/runtime/blob/BlobServerGetTest.java | 141 ++++++++++++++++-----
.../flink/runtime/blob/BlobServerPutTest.java | 58 +++++++--
.../apache/flink/runtime/blob/BlobUtilsTest.java | 36 +++++-
.../flink/runtime/blob/PermanentBlobCacheTest.java | 89 +++++++++++++
.../flink/runtime/blob/TestingBlobStore.java | 25 ++--
.../runtime/blob/TestingBlobStoreBuilder.java | 21 +--
.../flink/runtime/blob/TestingBlobUtils.java | 68 ++++++++++
.../flink/runtime/blob/TransientBlobCacheTest.java | 75 +++++++++++
.../dispatcher/DispatcherResourceCleanupTest.java | 2 +-
26 files changed, 717 insertions(+), 222 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/blob/PermanentBlobCacheTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/blob/TestingBlobUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/blob/TransientBlobCacheTest.java
