[FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

…apView.cleanup when destroying windows This closes apache#12358
mbalassi · May 28, 2020 · b6f92fe · b6f92fe
1 parent 3a322e0
commit b6f92fe
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...e-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java b/...e-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java
@@ -496,6 +496,7 @@ public void setWindowAccumulators(W window, RowData acc) throws Exception {
  public void clearWindowState(W window) throws Exception {
  windowState.setCurrentNamespace(window);
  windowState.clear();
+ windowAggregator.cleanup(window);
  }
 
  @Override