Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5995#discussion_r188353074
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
---
@@ -79,15 +87,16 @@
// -------- runtime fields, non-serializable, lazily initialized
-----------
- private transient SpecificDatumWriter<T> writer;
- private transient SpecificDatumReader<T> reader;
+ private transient GenericDatumWriter<T> writer;
+ private transient GenericDatumReader<T> reader;
private transient DataOutputEncoder encoder;
private transient DataInputDecoder decoder;
- private transient SpecificData avroData;
+ private transient GenericData avroData;
private transient Schema schema;
+ private final String schemaString;
--- End diff --
As per the comments, the existing code orders config fields before runtime
fields. Can you place the schema to match that pattern?
---
