我现在用的flinkcdc 监听binlog 进行消费使用，但是目前有一个问题，mysql随着时间的积累量大想进行数据备份到数仓里面，那么这个mysql 数据就会被删除。mysql—>binlog—>finkcdc—>sr删除。其实我这里如…

还有一种方法，就是停止任务->删数据->重启任务时更改flink-create.1.sql中的insert select语句为 insert into sink select * from source where date >‘2021-…