OOM

[esondeng]

一次性读取数据太多，造成OOM。按照官网说明在flink-conf.yaml设置了下面的参数也没用

The chunk size (number of rows) of table snapshot, captured tables are split into multiple chunks when read the snapshot of table.

scan.incremental.snapshot.chunk.size: 2048

he maximum fetch size for per poll when read table snapshot.

scan.snapshot.fetch.size: 256

cdc一次读取的数据行数

cdc.reader.fetch-size: 2000

错误信息如下，还需要什么设置不。
2023-07-07 14:47:00,579 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 225685 records for split 'egenie_baseinfo.platform_product_match:0' after 00:00:19.86
2023-07-07 14:47:05,652 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 114498 records for split 'egenie_baseinfo.platform_product_match:1' after 00:00:24.933
2023-07-07 14:47:11,803 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 285931 records for split 'egenie_baseinfo.platform_product_match:0' after 00:00:31.082
2023-07-07 14:47:17,222 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 154307 records for split 'egenie_baseinfo.platform_product_match:1' after 00:00:36.503
2023-07-07 14:47:22,892 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 306658 records for split 'egenie_baseinfo.platform_product_match:0' after 00:00:42.173
2023-07-07 14:47:28,384 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 163945 records for split 'egenie_baseinfo.platform_product_match:1' after 00:00:47.665
2023-07-07 14:47:33,909 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 311950 records for split 'egenie_baseinfo.platform_product_match:0' after 00:00:53.19
2023-07-07 14:47:39,390 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 166262 records for split 'egenie_baseinfo.platform_product_match:1' after 00:00:58.671
2023-07-07 14:47:45,214 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 313365 records for split 'egenie_baseinfo.platform_product_match:0' after 00:01:04.495
2023-07-07 14:47:52,457 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 167219 records for split 'egenie_baseinfo.platform_product_match:1' after 00:01:11.738
2023-07-07 14:47:57,005 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 314004 records for split 'egenie_baseinfo.platform_product_match:0' after 00:01:16.286
2023-07-07 14:48:07,657 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 314190 records for split 'egenie_baseinfo.platform_product_match:0' after 00:01:26.937
2023-07-07 14:48:07,657 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 167465 records for split 'egenie_baseinfo.platform_product_match:1' after 00:01:22.806
2023-07-07 14:48:18,978 INFO com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask [] - Exported 314290 records for split 'egenie_baseinfo.platform_product_match:0' after 00:01:38.258
2023-07-07 14:48:17,708 ERROR com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader [] - Execute snapshot read task for mysql split MySqlSnapshotSplit{tableId=egenie_baseinfo.platform_product_match, splitId='egenie_baseinfo.platform_product_match:1', splitKeyType=[platform_product_match_id BIGINT NOT NULL], splitStart=[12077194], splitEnd=[12482912], highWatermark=null} fail
java.lang.OutOfMemoryError: GC overhead limit exceeded

[esondeng]

jdbcProperties.setProperty("scan.incremental.snapshot.chunk.size", "1024");
jdbcProperties.setProperty("scan.snapshot.fetch.size", "256");
jdbcProperties.setProperty("reader.fetch-size", "2000");
数据库属性没有效果，大家知道还可以用啥配置吗

DatabaseSetting fromDatabaseSetting = drsSetting.getFromDatabaseSetting();
Pair<String, String> hostPortPair = buildHostPortPair(fromDatabaseSetting);
Pair<String[], String[]> databaseTablePair = buildDatabaseTablePair(drsSetting);

    Properties jdbcProperties = new Properties();
    jdbcProperties.setProperty("serverTimezone", DEFAULT_TIME_ZONE);
    jdbcProperties.setProperty("connection.timezone", DEFAULT_TIME_ZONE);
    //  这里的参数没有效果
    jdbcProperties.setProperty("scan.incremental.snapshot.chunk.size", "1024");
    jdbcProperties.setProperty("scan.snapshot.fetch.size", "256");
    jdbcProperties.setProperty("reader.fetch-size", "2000");


    // 为了方便使用，我们只支持全量+增量或者增量模式
    StartupOptions startupOptions = SyncMode.INITIAL.id() == drsSetting.getSyncMode() ? StartupOptions.initial() : StartupOptions.latest();

    return new MySqlSourceBuilder<ChangeRecord>()
            .hostname(hostPortPair.getLeft())
            .port(Integer.parseInt(hostPortPair.getRight()))
            .databaseList(databaseTablePair.getLeft())
            .tableList(databaseTablePair.getRight())
            .username(fromDatabaseSetting.getUserName())
            .serverTimeZone(DEFAULT_TIME_ZONE)
            .jdbcProperties(jdbcProperties)
            .password(fromDatabaseSetting.getPassword())
            .deserializer(new ChangeRecordDebeziumDeserializationSchema()
                    .setDrsSetting(drsSetting)
                    .setOptions(options)
                    .setDingTalkManager(dingTalkManager)
                    .setDrsJobManager(drsJobManager))
            .startupOptions(startupOptions)
            .scanNewlyAddedTableEnabled(true)
            // 忽略DDL事件
            .includeSchemaChanges(false)
            .build();