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 d0dcf81 [FLINK-25406] Let BlobUtils.moveTempFileToStore first write
file to BlobStore for persistence
add aa91a65 [FLINK-25436] Let TransientBlobCache register recovered
transient blobs with expiry times
add 1c220bd [FLINK-25436] Let PermanentBlobCache expire recovered
permanent blobs
add d9d8ebc [FLINK-25436] Let BlobServer automtically expire recovered
transient blobs
add 3e862a3 [FLINK-25436] Let Dispatcher only retain recovered jobs in
BlobServer
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/runtime/blob/BlobServer.java | 29 ++++++++
.../org/apache/flink/runtime/blob/BlobUtils.java | 87 ++++++++++++++++++++--
.../flink/runtime/blob/PermanentBlobCache.java | 25 +++++++
.../flink/runtime/blob/TransientBlobCache.java | 18 +++++
.../flink/runtime/dispatcher/Dispatcher.java | 2 +
.../flink/runtime/blob/BlobServerCleanupTest.java | 82 ++++++++++++++++----
.../apache/flink/runtime/blob/BlobUtilsTest.java | 10 ++-
.../flink/runtime/blob/PermanentBlobCacheTest.java | 27 +++++++
.../flink/runtime/blob/TransientBlobCacheTest.java | 25 +++++++
.../runtime/dispatcher/AbstractDispatcherTest.java | 4 +
.../dispatcher/DispatcherResourceCleanupTest.java | 41 +++++-----
.../flink/runtime/dispatcher/DispatcherTest.java | 24 ++++++
.../ZooKeeperDefaultDispatcherRunnerTest.java | 3 +-
13 files changed, 334 insertions(+), 43 deletions(-)
