Github user tragicjun commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r189437091
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -110,6 +116,8 @@ private void writeObject(ObjectOutputStream oos) throws
IOException {
oos.writeObject(recordClazz);
}
+
--- End diff --
nice catch.---
