From bc61b106550525fd4ce9c019679197f2e24fb582 Mon Sep 17 00:00:00 2001 From: Nie yingping Date: Fri, 11 Feb 2022 17:10:59 +0800 Subject: [PATCH 1/2] fixed some causing ambiguities comment fixed some causing ambiguities including the 'shit' comment --- .../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( From 5fca653e485890ca117ea7db0a13f3e12d057dde Mon Sep 17 00:00:00 2001 From: Nie yingping Date: Fri, 11 Feb 2022 17:14:01 +0800 Subject: [PATCH 2/2] fixed some causing ambiguities comment fixed some causing ambiguities including the 'shit' comment --- .../org/apache/flink/api/java/io/TypeSerializerInputFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerInputFormat.java b/flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerInputFormat.java index 4d935c3c0b2fa..cac9abc000958 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerInputFormat.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerInputFormat.java @@ -45,7 +45,7 @@ public class TypeSerializerInputFormat extends BinaryInputFormat public TypeSerializerInputFormat(TypeInformation resultType) { this.resultType = resultType; - // TODO: fix this shit + // TODO: fix this this.serializer = resultType.createSerializer(new ExecutionConfig()); }