Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r190169511
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -76,19 +77,35 @@
*/
private SpecificRecord record;
+ /** Type information describing the result type.
+ *
+ */
+ private final TypeInformation<Row> typeInfo;
--- End diff --
Declare this transient?---
