flink mysql cdc checkpoint恢复的时候，数据重复抽取了？

[ctysf]

flink mysql cdc connector,当作业出现checkpoint恢复的时候，原有的cdc连接保持没有清除，然后会新增加一个连接来抽取cdc数据。
从source的subtask观察得到，每ck重启一次，就会多一个subtask往下游发送数据，数据库的l连接也会多一条。有没有什么方法解决。