大佬们,flinkcdc用sql的方式怎么得到mysql产生数据的时间?就是这个操作时间,flink程序重启以后他是跟着操作的时间还是1970-01-01?只有第一次全量同步的时候时间是1970-01-01,以后就是从checkpoint启动他的时间是从1970-01-01开始,还是后面最新的时间?
mysql数据如果自己不带时间的话,可以从元数据获取operator_ts,但只有从binlog消费这个数据才不为0。官网有讲,这个你可以测试下呢?我没有进一步使用过这个元数据时间,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。