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

Posted to dev@flink.apache.org by "Yue Ma (Jira)" <ji...@apache.org> on 2025/03/12 06:16:00 UTC

[jira] [Created] (FLINK-37463) Make ForStMapState Serializer ThreadLocal

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)