You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/05/28 03:14:19 UTC
[flink] branch release-1.11 updated:
[FLINK-17942][table-planner-blink] Fix WindowOperator not call
StateMapView.cleanup when destroying windows
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 661541a [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateMapView.cleanup when destroying windows
661541a is described below
commit 661541a1f002778df0691b05fe828a72870746dc
Author: Benchao Li <li...@gmail.com>
AuthorDate: Thu May 28 11:11:48 2020 +0800
[FLINK-17942][table-planner-blink] Fix WindowOperator not call StateMapView.cleanup when destroying windows
This closes #12358
---
.../org/apache/flink/table/runtime/operators/window/WindowOperator.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java
index eb9c907..120a13e 100644
--- a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java
+++ b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java
@@ -496,6 +496,7 @@ public abstract class WindowOperator<K, W extends Window>
public void clearWindowState(W window) throws Exception {
windowState.setCurrentNamespace(window);
windowState.clear();
+ windowAggregator.cleanup(window);
}
@Override