[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-----------------------------
Description:
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]
was:
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]
黑客帝国
> 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
> Priority: Major
>
> 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]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
