Ted Yu created FLINK-3329:
-----------------------------
Summary: Unclosed BackupEngine in AbstractRocksDBState#snapshot()
Key: FLINK-3329
URL:
https://issues.apache.org/jira/browse/FLINK-3329 Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Here is related code:
{code}
BackupEngine backupEngine = BackupEngine.open(Env.getDefault(),
new BackupableDBOptions(localBackupPath.getAbsolutePath()));
backupEngine.createNewBackup(db);
{code}
BackupEngine implements AutoCloseable.
backupEngine should be closed upon return from the method.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)