Flink MySQL CDC时区不一致的原因
已解决
收起
提个问题!
2024-05-24 14:06:32
53
0
1
条回答
写回答
取消
提交回答
-
在解析binlog数据中的timestamp字段时,cdc会使用到作业里配置的server-time-zone信息,也就是MySQL服务器的时区,如果这个时区没有和你的MySQL服务器时区一致,就会出现时区的问题,vvp默认是utc+8。
此外,如果是在DataStream作业中自定义列化器如MyDeserializer implements DebeziumDeserializationSchema, 自定义的序列化器在解析timestamp类型数据时,需要参考下RowDataDebeziumDeserializeSchema中对timestamp类型的解析,用时给定的时区信息。
2024-05-24 14:06:33