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)