[jira] [Updated] (FLINK-8676) Memory Leak in AbstractKeyedStateBackend.applyToAllKeys() when backend is base on RocksDB

["Kostas Kloudas (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kostas Kloudas updated FLINK-8676:
----------------------------------
    Component/s: Streaming
                 State Backends, Checkpointing

> 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
>          Components: State Backends, Checkpointing, Streaming
>    Affects Versions: 1.5.0
>            Reporter: Sihua Zhou
>            Assignee: Sihua Zhou
>            Priority: Blocker
>             Fix For: 1.5.0
>
>
> `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)