[flink] branch release-1.15 updated: [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection

[yuanmei]

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;
         }