[FLINK-5530] race condition in AbstractRocksDBState#getSerializedValue

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0, 1.3.0
• Component/s: Runtime / Queryable State
• Assignee: Nico Kruber
• Reporter: Nico Kruber
• Created: 17/Jan/17 14:48
• Updated: 22/Jan/17 10:46
• Resolved: 22/Jan/17 10:46

Description

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.

Issue Links

• links to: GitHub Pull Request #3143