[ 
https://issues.apache.org/jira/browse/FLINK-39740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18083167#comment-18083167
 ] 

Roman Khachatryan commented on FLINK-39740:
-------------------------------------------

Merged to master as f08eb4345004b1422d100fccdee9667804122ad2 (along with 
hotfixes f08eb4345004b1422d100fccdee9667804122ad2 and 
6f422510a8f3150ac67d40d30cca67065a8c54e5)

> 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
>            Priority: Major
>              Labels: pull-request-available
>
> 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)

Reply via email to