You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/16 17:26:00 UTC
[jira] [Created] (FLINK-8676) Memory Leak in
AbstractKeyedStateBackend.applyToAllKeys() when backend is base on RocksDB
Sihua Zhou created FLINK-8676:
---------------------------------
Summary: Memory Leak in AbstractKeyedStateBackend.applyToAllKeys() when backend is base on RocksDB
Key: FLINK-8676
URL: https://issues.apache.org/jira/browse/FLINK-8676
Project: Flink
Issue Type: Bug
Reporter: Sihua Zhou
Assignee: Sihua Zhou
`AbstractKeyedStateBackend.applyToAllKeys() ` uses backend's getKeys(stateName, namespace) to get all keys that belong to `namespace`. But, in `RocksDBKeyedStateBackend.getKeys()` if just return a object which wrap a `rocksdb iterator`, that is dangous, because rocksdb will ping the resources that belong to the iterator into memory untill iterator.close() is invoked, but it didn't invoked right now. This will lead to memory leak finally.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)