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

Posted to commits@flink.apache.org by sr...@apache.org on 2023/08/01 14:20:24 UTC

[flink] branch master updated (9e6f8e8e127 -> d11cc32948b)

This is an automated email from the ASF dual-hosted git repository.

srichter pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 9e6f8e8e127 [FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained with a MultipleInput node.
     add d11cc32948b [FLINK-32681] Wait for RocksDBStateDownloader threads on failure to ensure proper cleanup.

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/core/fs/CloseableRegistry.java    |  26 +++++
 .../flink/core/fs/CloseableRegistryTest.java       | 108 +++++++++++++++++++++
 .../streaming/state/RocksDBStateDownloader.java    |  50 ++++------
 .../state/RocksDBStateDownloaderTest.java          |   6 +-
 4 files changed, 158 insertions(+), 32 deletions(-)