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?


---

Reply via email to