flink cdc遇到数据源大事务怎么处理？

[casel.chen]

flink cdc对接上游的mysql或pg业务库时遇到业务库大批量修数或schema变更是怎么处理的？
会不会瞬间产生很多changelog records打爆flink应用？如果会的话应该要如何避免呢？谢谢！