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)
