![个人头像照片](https://ucc.alicdn.com/avatar/542a0fe909604fe7989c63bc8f4c48f0.jpeg)
雪尽@Flink CDC
2022年10月
社区用户建议将分库分表单独拆分出来,目前分库分表会推导最宽的schema,也可以用datastream api 自己处理下这种schema不一致的case。如果是阿里云的实时计算flink版用户,可以考虑用CDAS语法做整库同步,后者也处理了这种情况。
可能需要贴下具体的SQL和使用的表的DDL语句,这样比较好判断一点。有个区别是 union 和union all,前者会做全局聚合去重,后者不会。
看起来是依赖冲突的问题,目前flink cdc 社区只支持到flink 1.14,如果需要再flink 1.15.2需要自己编译,自己编译可以参考这个PR[1],flink cdc 社区很快也会发布包含这个PR的2.3版本。 [1]https://github.com/ververica/flink-cdc-connectors/pull/1504