Ted Yu created FLINK-9018:
-----------------------------
Summary: Unclosed snapshotCloseableRegistry in
RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot
Key: FLINK-9018
URL: https://issues.apache.org/jira/browse/FLINK-9018
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
{code}
final CloseableRegistry snapshotCloseableRegistry = new
CloseableRegistry();
if (kvStateInformation.isEmpty()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Asynchronous RocksDB snapshot performed on empty keyed
state at {}. Returning null.",
timestamp);
}
return DoneFuture.of(SnapshotResult.empty());
}
{code}
If the method returns in the above if block, snapshotCloseableRegistry is not
closed.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
