You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2021/10/21 06:22:00 UTC
[jira] [Commented] (FLINK-24606) AvroDeserializationSchema buffer
is not clean
[ 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)