[jira] [Created] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot

[Shang Yuanchun (Jira)]

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)