短时爆发数据处理方案

[lewnn]

Yarn-session，Oracle-Cdc中使用DataStream Source，一次同步多个表数据。但是当某个表短时间内（比如：一次修改了1kw条记录的一列标志信息），source会一次性读取日志到TM中，造成TM内存击穿，挂掉，且如果配置了失败重启次数后，也不会从失败点回复
请问：

1. 是否存在source的类似反压策略，内存不足时，挂起拉取数据线程，内存低于警戒值时唤醒拉取线程
2. 是否可以配置批次拉取（在 https://ververica.github.io/flink-cdc-connectors/master/index.html 中没看到相关参数），Debezium是否有类似参数
3. source的拉取数据是否可以在内存不足时，落地到磁盘中

[lewnn]

need help