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

Posted to commits@flink.apache.org by tr...@apache.org on 2022/01/19 15:47:22 UTC

[flink] branch master updated (d0dcf81 -> 3e862a3)

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(-)