Roman Khachatryan created FLINK-39740:
-----------------------------------------
Summary: LinkedMultiSetState updates highestSqnAndSizeState
unconditionally
Key: FLINK-39740
URL: https://issues.apache.org/jira/browse/FLINK-39740
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 2.3.0
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
In LinkedMultiSetState, highestSqnAndSizeState tracks the highest SQN. It grows
monotinically and is used when linking rows in a double-linked list.
To preserve monotonicity, it should only be incremented on new rows.
However, it is currently updated (to a lower value) when a row is replaced,
breaking the invariant.
Linking of the next row added will be broken.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
