heyu dou created FLINK-30548:
--------------------------------
Summary: In some cases AvroDeserializationSchema buffer is not
reset
Key: FLINK-30548
URL: https://issues.apache.org/jira/browse/FLINK-30548
Project: Flink
Issue Type: Bug
Reporter: heyu dou
When the avro schema changes, if the downstream uses the old schema to read the
data generated by the new schema
The buffer pos of AvroDeserializationSchema.decoder will not be reset
This will result in misaligned reads
Because AvroDeserializationSchema.decoder is reuse and not reset pos
https://github.com/apache/flink/blob/99c2a415e9eeefafacf70762b6f54070f7911ceb/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java#L165
[the|http://dict.youdao.com/search?q=the&keyfrom=chrome.extension] [ðə; ði]
[详细|http://dict.youdao.com/search?q=the&keyfrom=chrome.extension]X
基本翻译
art. 这；那
adv. 更加（用于比较级，最高级前）
网络释义
[THE:|http://dict.youdao.com/search?q=THE&keyfrom=chrome.extension&le=eng]
泰晤士高等教育(Times Higher Education)
[The
Sun:|http://dict.youdao.com/search?q=The%20Sun&keyfrom=chrome.extension&le=eng]
太阳报
[The
Matrix:|http://dict.youdao.com/search?q=The%20Matrix&keyfrom=chrome.extension&le=eng]
黑客帝国
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
