zhanghuaibei created FLINK-36365:
------------------------------------

             Summary: The fetchsize parameter of 
flink-sql-connector-mysql-cdc-3.2.0 does not take effect
                 Key: FLINK-36365
                 URL: https://issues.apache.org/jira/browse/FLINK-36365
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
    Affects Versions: cdc-3.2.0
         Environment: Flink version is 1.15.2

flink-sql-connector-mysql-cdc-3.20.jar,

mysql-connector-java-8.0.27.jar

flink-sql-connector-mysql-cdc-3.2.0
            Reporter: zhanghuaibei


The Flink version is 1.15.2, flink-sql-connector-mysql-cdc-3.20.jar, 
mysql-connector-java-8.0.27.jar, flink-sql-connector-mysql-cdc-3.2.0, scan. 
cremental. snapshot. chunk. size=4. The data in one MySQL table is 6G, the 
memory in taskmanager is set to 2G, and the memory in jobmanager is set to 2G. 
After startup, jobmanager crashes. How to determine if the current version 
fully synchronizes MySQL data and stream reads are effective



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

Reply via email to