[
https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-24606:
-----------------------------
Description:
org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse
org.apache.avro.io.BinaryDecoder.
But the way it is used is wrong.
Should be reset Decoder before deserialization().
if not, when schema change, the last result will be enter the current.
was:
org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse
org.apache.avro.io.BinaryDecoder.
But the way it is used is wrong.
Should be reset Decoder before deserialization().
> AvroDeserializationSchema buffer is not clean
> ---------------------------------------------
>
> Key: FLINK-24606
> URL: https://issues.apache.org/jira/browse/FLINK-24606
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Reporter: heyu dou
> Priority: Major
>
> org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse
> org.apache.avro.io.BinaryDecoder.
> But the way it is used is wrong.
> Should be reset Decoder before deserialization().
> if not, when schema change, the last result will be enter the current.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
