You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 14:49:26 UTC

[jira] [Created] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

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)