[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476136#comment-16476136
]
ASF GitHub Bot commented on FLINK-9337:
---------------------------------------
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?
> Implement AvroDeserializationSchema
> -----------------------------------
>
> Key: FLINK-9337
> URL: https://issues.apache.org/jira/browse/FLINK-9337
> Project: Flink
> Issue Type: New Feature
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Major
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
