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