[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Attachment: AvroNew.java
AvroOld.java
> In some cases AvroDeserializationSchema buffer
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> In some cases AvroDeserializationSchema
[
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
