Flink Cdc MySQL 整库同步到 StarRocks

Open guohuawei opened this issue 3 years ago • 1 comments

大佬，在CustomDebeziumDeserializationSchema 里面的 parseRecord这个方法里面的枚举值好像列举的不全吧？假如我mysql端的数据类型（decimal、date、datetime）在这个枚举里面找不到，数据就会被丢弃，比如我一行数据有三列，假如有一列数据类型匹配不上，就会变成两列。。。。从而导入失败(ps：不知道我这样理解的对不对。。。)

Nov 24 '22 08:11 guohuawei

你好，始终没找到 "Flink Cdc MySQL 整库同步到 StarRocks"的完整代码，方便贴一下路径么，谢谢

Sep 05 '23 10:09 yangtzelsl