Yue Ma created FLINK-37463:
------------------------------
Summary: Make ForStMapState Serializer ThreadLocal
Key: FLINK-37463
URL: https://issues.apache.org/jira/browse/FLINK-37463
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 2.0.0
Reporter: Yue Ma
Fix For: 2.0.0
Now, when using *_ForStMapState_* for asynchronous state reading and writing,
*_userValueSerializer_* in _ForStMapState_ will be used to serialize and
deserialize the data. However, in asynchronous execution mode, multiple threads
may use the same *_userValueSerializer_* instance for serialization and
deserialization at the same time, which may cause some multi-thread conflicts
in Serializer (eg: Kryo), so we need to make the *_userValueSerializer_* and
*_userKeySerializer_* in *_ForStMapState_* ThreadLocal to avoid these problems.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
