Flink cdc sqlserver 希望不同步某些数据行

在sql使用where过滤,如员工表,不同步age = 21的员工。
已同步11岁员工到下游数据库后,修改为21岁。会导致下游数据已同步的11岁记录被删除。如何能保留已同步的记录

展开
收起
s2xnazfzed5gw 2026-07-16 14:36:58 21 分享 版权
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理