各位老师请问有谁能帮忙告知下flink1.16.1，flink mysql cdc2.3.0读取my
各位老师请问有谁能帮忙告知下flink1.16.1，flink mysql cdc2.3.0读取mysql数据，initial模式，不报错也不输出数据可能的原因吗？
用flink1.13.6，cdc2.2可以读出来，开启了，有数据的，之前一直用的这个版本测试，后面领导说要升级成1.16.1的版本，就读不出数据了，换成1.16.0也不行，看了。也试了用1.15.4，数据也出不来，没爆出来更多日子就一直没输出。也不知道怎么排查了
代码就最基础的查询打印，我配置下在调试下，大佬这个参数怎么加？我就是普通的SQL 两个平台对比，发现时间不一样，大佬说的我这都没有涉及到了，我同步mysql把所有的类型都换成了string
大佬你说的这个调时区是说加这个参数嘛？
我加的有这个参数了 我这个库下 就这一张表的时间对不上别的都没有问题
您看 MySQL是时间类型，我cdc实时同步的时候就转成了string
写回答
-
你的mysql配置修改了没有，开启了binlog没有，你的那张表有数据吗？cdc2.3 不支持1.16.1啊，没看文档吗，这个要看日志的，断点，一层一层走 这个不是没有日志 是没找到 log4j 的配置文件 所以没有日志打印，resources都没有配置，不就是问你用什么查吗，这是flink类型，那调mysql时区应该可以吧 你看了mysql所在机器的时区和flink所在时区和hudi所在时区了吗？ 是，不知道你是怎么样转成字符 串，你从RowDataDebeziumDeserializeSchema调试一下，类型问题吧？你cdc转成string不是自己操作的吗，此回答整理自钉群“Flink CDC 社区”
2023-05-01 17:28:02赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
热门讨论
热门文章
相关课程
更多
相关电子书
更多
