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 f3f7d994dc0ea476a524c8179cb2dbe70ae5c4c4 Author: Tzu-Li (Gordon) Tai <[email protected]> AuthorDate: Wed Dec 23 13:03:14 2020 +0800 [hotfix] isUsingCustomRawKeyedState should be set on FeedbackUnionOperator --- .../flink/statefun/flink/core/feedback/FeedbackUnionOperator.java | 5 +++++ .../flink/statefun/flink/core/functions/FunctionGroupOperator.java | 5 ----- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java index efed323..fb68cc4 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java @@ -146,6 +146,11 @@ public final class FeedbackUnionOperator<T> extends AbstractStreamOperator<T> } @Override + protected boolean isUsingCustomRawKeyedState() { + return true; + } + + @Override public void close() throws Exception { closeInternally(); super.close(); 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 37a4cdc..741575b 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,11 +151,6 @@ public class FunctionGroupOperator extends AbstractStreamOperator<Message> } @Override - protected boolean isUsingCustomRawKeyedState() { - return true; - } - - @Override public void close() throws Exception { try { closeOrDispose();
