You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Kenneth William Krugler (Jira)" <ji...@apache.org> on 2020/07/24 13:57:00 UTC
[jira] [Created] (FLINK-18707) Calling remove() for RockDB
ListState iterator does nothing
Kenneth William Krugler created FLINK-18707:
-----------------------------------------------
Summary: Calling remove() for RockDB ListState iterator does nothing
Key: FLINK-18707
URL: https://issues.apache.org/jira/browse/FLINK-18707
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 1.9.2
Reporter: Kenneth William Krugler
If you use the FsStateBackend (or MemoryStateBackend), and you have ListState, then you can get an iterator and remove() an entry, and it all works as expected.
If you use the RocksDBStateBackend, the remove() call doesn’t throw an exception, but the ListState isn’t updated.
As [~aljoscha] noted:
{quote}We cannot efficiently implement it [remove] for RocksDB
{quote}
So an exception should be thrown when calling remove() call.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)