This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 01e0593590372269bb95d862bb4a2ce5751f0c47 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 381a672..ae7a61d 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 @@ -166,6 +166,11 @@ public class FunctionGroupOperator extends AbstractStreamOperator<Message> } @Override + protected boolean isUsingCustomRawKeyedState() { + return true; + } + + @Override public void close() throws Exception { try { closeOrDispose();
