[
https://issues.apache.org/jira/browse/FLINK-26967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-26967:
--------------------------------------
Description:
Currently, handling chained entry on copy-on-write uses object
identity to find the wanted entry in the chain. However, if
the same method is running concurrently, the object in the chain
can be replaced by its copy; the condition will never be met and
the chain end will be reached, causing an NPE.
> Fix race condition in CopyOnWriteStateMap
> -----------------------------------------
>
> Key: FLINK-26967
> URL: https://issues.apache.org/jira/browse/FLINK-26967
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / State Backends
> Reporter: Roman Khachatryan
> Priority: Major
> Fix For: 1.16.0
>
>
> Currently, handling chained entry on copy-on-write uses object
> identity to find the wanted entry in the chain. However, if
> the same method is running concurrently, the object in the chain
> can be replaced by its copy; the condition will never be met and
> the chain end will be reached, causing an NPE.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
