[
https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17432219#comment-17432219
]
Nicholas Jiang commented on FLINK-24606:
----------------------------------------
[~douheyu], IMO, the decoder in AvroDeserializationSchema doesn't support for
the reuse of BinaryDecoder because the reuse decoder is null when calling
binaryDecoder() method. Therefore, if we need to reuse the BinaryDecoder, this
caller should pass the reused BinaryDecoder.
> 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)
