This is an automated email from the ASF dual-hosted git repository. rkhachatryan pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 198ea6ae646785bbb34b463626281a2f95502d12 Author: Roman Khachatryan <[email protected]> AuthorDate: Fri Mar 13 13:09:41 2026 +0100 [hotfix][table/runtime] Remove redundant state access in LinkedMultiSetState.add --- .../runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java index 801bab4a973..9ab37d94200 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java @@ -154,7 +154,7 @@ public class LinkedMultiSetState implements SequencedMultiSetState<RowData> { final Long highSqn = highSqnAndSize == null ? null : highSqnAndSize.highSqn; final long oldSize = highSqnAndSize == null ? 0 : highSqnAndSize.size; final RowSqnInfo rowSqnInfo = rowToSqnState.get(key); - final Long rowSqn = rowSqnInfo == null ? null : rowToSqnState.get(key).firstSqn; + final Long rowSqn = rowSqnInfo == null ? null : rowSqnInfo.firstSqn; final boolean isNewRowKey = rowSqn == null; // it's a 1st such record 'row' final boolean isNewContextKey = highSqn == null; // 1st a record for current context key
