jinshuangxian created FLINK-28251:
-------------------------------------
Summary: flink-avro format reader may thrown
’java.util.NoSuchElementException' Exception in some cases
Key: FLINK-28251
URL: https://issues.apache.org/jira/browse/FLINK-28251
Project: Flink
Issue Type: Bug
Affects Versions: 1.15.0
Environment: flink 1.15.0
centos7
Reporter: jinshuangxian
Attachments: image-2022-06-25-22-14-31-301.png,
image-2022-06-25-22-25-17-507.png, image-2022-06-25-22-27-06-418.png
my source table is :
CREATE TABLE fileTable (
data bytes
)
WITH (
'connector' = 'filesystem',
'source.monitor-interval' = '60s',
'path' = '${bucket}/${dirname}',
'format' = 'avro'
);
After running for a period of time, it is possible to throw the following
Exception:
!image-2022-06-25-22-14-31-301.png!
I found that the following two codes may have bugs. After modification, they
can run stably Online.
!image-2022-06-25-22-25-17-507.png!
!image-2022-06-25-22-27-06-418.png!
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
