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:12:42 UTC
[flink] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b6f92fe [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateMapView.cleanup when destroying windows
b6f92fe is described below
commit b6f92febd1f03152541432492820a5f2a12be6c4
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