[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653916#comment-17653916
]
heyu dou commented on FLINK-30548:
--
If you agree, can you let me modify it?
> In some cases
[
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
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
heyu dou created FLINK-30502:
Summary: Checkpoint state Continued to increase
Key: FLINK-30502
URL: https://issues.apache.org/jira/browse/FLINK-30502
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-24606:
-
Description:
org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse
heyu dou created FLINK-24606:
Summary: AvroDeserializationSchema buffer is not clean
Key: FLINK-24606
URL: https://issues.apache.org/jira/browse/FLINK-24606
Project: Flink
Issue Type: Bug
11 matches
Mail list logo