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()); }