flink cdc时间问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink cdc时间问题

赵帅
关于cdc有个问题,求大佬能否解释下,是解析bin log的bug还是自己代码bug;



mysql数据库中表,创建时间和修改时间设置为current_timestamp


场景一:插入数据
插入数据时忽略创建时间和修改时间字段


cdc接入后,转存到hbase中,转为字符串时间,时间少8个小时


确认了,程序运行的服务器时间、mysql服务器的时间,和hbase服务器的时间,均为UTC+0800时区


场景二:重启服务,重新读取数据
此时cdc接入数据,会将最后的数据拿出来写入hbase,此时按照同样的执行,数据库时间也是放的正确时间,hbase时间也能吻合


场景二佐证了场景一中的所有环境时间时区统一问题




求问下,场景一中出现此情况的原因