Skip to content

Commit 198ea6a

Browse files
committed
[hotfix][table/runtime] Remove redundant state access in LinkedMultiSetState.add
1 parent f08eb43 commit 198ea6a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/sequencedmultisetstate/linked/LinkedMultiSetState.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ public StateChangeInfo<RowData> add(RowData row, long timestamp) throws Exceptio
154154
final Long highSqn = highSqnAndSize == null ? null : highSqnAndSize.highSqn;
155155
final long oldSize = highSqnAndSize == null ? 0 : highSqnAndSize.size;
156156
final RowSqnInfo rowSqnInfo = rowToSqnState.get(key);
157-
final Long rowSqn = rowSqnInfo == null ? null : rowToSqnState.get(key).firstSqn;
157+
final Long rowSqn = rowSqnInfo == null ? null : rowSqnInfo.firstSqn;
158158
final boolean isNewRowKey = rowSqn == null; // it's a 1st such record 'row'
159159
final boolean isNewContextKey = highSqn == null; // 1st a record for current context key
160160

0 commit comments

Comments
 (0)