[jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

Shang Yuanchun (Jira)
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)