[
https://issues.apache.org/jira/browse/FLINK-37463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37463:
-------------------------------
Fix Version/s: 2.1.0
(was: 2.0.0)
> 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.1.0
> Reporter: Yue Ma
> Assignee: Yue Ma
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.1.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)
