[jira] [Created] (FLINK-28400) Customize table source. After inheriting Richparallelsourcefunction class, data disorder under Multiple Parallelism

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

thecai created FLINK-28400:
------------------------------

             Summary: Customize table source. After inheriting Richparallelsourcefunction class, data disorder under Multiple Parallelism
                 Key: FLINK-28400
                 URL: https://issues.apache.org/jira/browse/FLINK-28400
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / API
    Affects Versions: 1.12.0
         Environment: <properties>
<java.version>1.8</java.version>
<maven.compiler.source>${java.version}</maven.compiler.source>
<maven.compiler.target>${java.version}</maven.compiler.target>
<flink.version>1.12.0</flink.version>
<scala.binary.version>2.12</scala.binary.version>
<hadoop.version>3.1.3</hadoop.version>
</properties>
            Reporter: thecai
             Fix For: 1.7.3
         Attachments: ESSourceFunction-1.java, ESSourceFunction.java, image-2022-07-05-16-49-41-235.png, image-2022-07-05-16-50-20-394.png, image-2022-07-05-16-50-30-563.png

[^ESSourceFunction.java]

^The cycle of life and death occurs on line 118；^

^However, when inheriting the Richsourcefunction class, there will be no life and death cycle,but the speed of reading data is flow；^

^maybe the Richsourcefunction thread unsafe suspexted;^



--
This message was sent by Atlassian Jira
(v8.20.10#820010)