This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit be6e7c5c3492e529d7b47252952f25c33b4d1b1b Author: Rui Fan <[email protected]> AuthorDate: Thu Nov 27 20:54:10 2025 +0100 [hotfix] WindowBuffer implements AutoCloseable to avoid declare close explicitly --- .../runtime/operators/aggregate/window/buffers/WindowBuffer.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/WindowBuffer.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/WindowBuffer.java index 9fc7d81d72a..044297a96d7 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/WindowBuffer.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/WindowBuffer.java @@ -36,7 +36,7 @@ import java.time.ZoneId; * frequently accessing state, or flushes to output to reduce shuffling data. */ @Internal -public interface WindowBuffer { +public interface WindowBuffer extends AutoCloseable { /** * Adds an element with associated key into the buffer. The buffer may temporarily buffer the @@ -72,9 +72,6 @@ public interface WindowBuffer { */ void flush() throws Exception; - /** Release resources allocated by this buffer. */ - void close() throws Exception; - // ------------------------------------------------------------------------ /** A factory that creates a {@link WindowBuffer}. */
