This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 5ea3958757b8cb3557dc57fac309ce94ddf9ec81 Author: Tzu-Li (Gordon) Tai <[email protected]> AuthorDate: Mon Dec 21 15:17:22 2020 +0800 [FLINK-19741] Set isUsingCustomRawKeyedState flag in FunctionGroupOperator See FLINK-19741. Now that we have upgraded to Flink 1.11.3, this flag is now available for us to override. This would enable restoring from savepoints containing feedback elements from versions earlier than 2.2.1. This closes #189. --- .../flink/statefun/flink/core/functions/FunctionGroupOperator.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java index 741575b..37a4cdc 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java @@ -151,6 +151,11 @@ public class FunctionGroupOperator extends AbstractStreamOperator<Message> } @Override + protected boolean isUsingCustomRawKeyedState() { + return true; + } + + @Override public void close() throws Exception { try { closeOrDispose();
