[jira] [Created] (FLINK-28251) flink-avro format reader may thrown ’java.util.NoSuchElementException' Exception in some cases

["jinshuangxian (Jira)" <ji...@apache.org>]

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)