[flink] branch master updated: [FLINK-23276][state/changelog] Fix missing delegation in getPartitionedState

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 95ea0da  [FLINK-23276][state/changelog] Fix missing delegation in getPartitionedState
95ea0da is described below

commit 95ea0da61f26afbe9d3499791e1a95895d714dff
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Mon Jul 5 22:23:47 2021 +0200

    [FLINK-23276][state/changelog] Fix missing delegation in getPartitionedState
    
    Changelog backend creates delegating functions on recovery
    so that user can later provide function code.
    
    Some branches do not register delegates currently,
    this change fixes it.
---
 .../org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
index 375ced2..4770091 100644
--- a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
+++ b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
@@ -284,6 +284,7 @@ public class ChangelogKeyedStateBackend<K>
             lastState = previous;
             lastState.setCurrentNamespace(namespace);
             lastName = stateDescriptor.getName();
+            functionDelegationHelper.addOrUpdate(stateDescriptor);
             return (S) previous;
         }