[ https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
JunboWang updated FLINK-37120: ------------------------------ Description: When synchronizing a large table, the ending chunk is always executed last, and splitEnd is null. This causing the task to scan too much data and eventually TaskManager OOM. (was: When synchronizing a large table, the last chunk is always executed last, and splitEnd is null. This causing the task to scan too much data and eventually TaskManager OOM.) > MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager > OOM > --------------------------------------------------------------------------------- > > Key: FLINK-37120 > URL: https://issues.apache.org/jira/browse/FLINK-37120 > Project: Flink > Issue Type: Improvement > Components: Flink CDC > Affects Versions: cdc-3.2.1 > Reporter: JunboWang > Priority: Minor > > When synchronizing a large table, the ending chunk is always executed last, > and splitEnd is null. This causing the task to scan too much data and > eventually TaskManager OOM. -- This message was sent by Atlassian Jira (v8.20.10#820010)