[FLINK-10175] Fix concurrent access to shared buffer in map state / querable state

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.7.0
• Fix Version/s: 1.7.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Stefan Richter
• Reporter: Stefan Richter
• Created: 20/Aug/18 09:06
• Updated: 21/Nov/18 10:58
• Resolved: 22/Aug/18 11:35

Description

Accidental sharing of buffers between event processing loop and queryable state thread can happen in RocksDBMapState::deserializeUserKey. Queryable state should provide a separate buffer.

Issue Links

• causes: FLINK-10111 Test failure because of HAQueryableStateFsBackendITCase#testMapState throws NPE
• is duplicated by: FLINK-10138 Queryable state (rocksdb) end-to-end test failed on Travis
• is related to: FLINK-10138 Queryable state (rocksdb) end-to-end test failed on Travis
• links to: GitHub Pull Request #6583