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)
