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(