This is an automated email from the ASF dual-hosted git repository. yuanmei pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push: new 778a15c8 [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection 778a15c8 is described below commit 778a15c8e1cda342ea39ad373334bbe9ffca0a5e Author: wangfeifan <zoltar9...@163.com> AuthorDate: Mon Mar 21 17:42:54 2022 +0800 [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection --- .../flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java index f9fd504..5a996b2 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java @@ -100,7 +100,7 @@ public final class ChangelogStateHandleStreamImpl implements ChangelogStateHandl @Nullable @Override public KeyedStateHandle getIntersection(KeyGroupRange keyGroupRange) { - KeyGroupRange offsets = keyGroupRange.getIntersection(keyGroupRange); + KeyGroupRange offsets = this.keyGroupRange.getIntersection(keyGroupRange); if (offsets.getNumberOfKeyGroups() == 0) { return null; }