[FLINK-23367] testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

• Type: Sub-task
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Yun Tang
• Reporter: Yuan Mei
• Created: 13/Jul/21 04:42
• Updated: 30/Aug/21 21:12
• Resolved: 16/Jul/21 09:58

Description

The set of `testKeyGroupedInternalPriorityQueue` for `ChangelogDelegateEmbeddedRocksDBStateBackendTest` does not dispose rocksdb properly.

It seems it creates one more than needed column family in the `ChangelogDelegateEmbeddedRocksDBStateBackendTest` case comparing to `EmbeddedRocksDBStateBackend`

// ... continue with the ones created by Flink...
for (RocksDbKvStateInfo kvStateInfo : kvStateInformation.values())

{ RocksDBOperationUtils.addColumnFamilyOptionsToCloseLater( columnFamilyOptions, kvStateInfo.columnFamilyHandle); IOUtils.closeQuietly(kvStateInfo.columnFamilyHandle); }

Issue Links

• links to: GitHub Pull Request #16512