You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/12/23 05:15:53 UTC
[flink-statefun] 01/03: [hotfix] isUsingCustomRawKeyedState should
be set on FeedbackUnionOperator
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 <tz...@apache.org>
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();