Nico Kruber created FLINK-5530:
----------------------------------

             Summary: race condition in AbstractRocksDBState#getSerializedValue
                 Key: FLINK-5530
                 URL: https://issues.apache.org/jira/browse/FLINK-5530
             Project: Flink
          Issue Type: Bug
          Components: Queryable State
    Affects Versions: 1.2.0
            Reporter: Nico Kruber
            Assignee: Nico Kruber
            Priority: Blocker


AbstractRocksDBState#getSerializedValue() uses the same key serialisation 
stream as the ordinary state access methods but is called in parallel during 
state queries thus violating the assumption of only one thread accessing it. 

This may lead to either wrong results in queries or corrupt data while queries 
are executed.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to