From 6b9346757087dc30d093af211911925731d71ef5 Mon Sep 17 00:00:00 2001 From: Kyle Dong Date: Mon, 6 Jun 2022 11:36:04 +0800 Subject: [PATCH] Fixed typo --- .../operators/aggregate/window/buffers/WindowBuffer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 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 4f86659d7121d..ad020c4fec066 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 @@ -93,7 +93,7 @@ interface Factory extends Serializable { * @param windowState the window state to flush buffered data into. * @param isEventTime indicates whether the operator works in event-time or processing-time * mode, used for register corresponding timers. - * @param shiftTimeZone the shit timezone of the window + * @param shiftTimeZone the shift timezone of the window * @throws IOException thrown if the buffer can't be opened */ WindowBuffer create( @@ -121,7 +121,7 @@ interface LocalFactory extends Serializable { * @param memoryManager the manager that governs memory by Flink framework * @param memorySize the managed memory size can be used by this operator * @param collector collector to emit records - * @param shiftTimeZone the shit timezone of the window + * @param shiftTimeZone the shift timezone of the window * @throws IOException thrown if the buffer can't be opened */ WindowBuffer create(