[ https://issues.apache.org/jira/browse/FLINK-36806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933703#comment-17933703 ]
ouyangwulin commented on FLINK-36806: ------------------------------------- Not only does this issue occur with Iceberg writes, but similar problems are also found in other downstream systems like Paimon. Do we have a universal solution for this? I remember that Congxian Qiu shared something about it. > Support for synchronization between timestamp fields with and without time > zones to avoid time offsets > ------------------------------------------------------------------------------------------------------ > > Key: FLINK-36806 > URL: https://issues.apache.org/jira/browse/FLINK-36806 > Project: Flink > Issue Type: Improvement > Components: Flink CDC > Affects Versions: cdc-3.1.0, cdc-3.3.0, cdc-3.2.1 > Reporter: zjjiang > Priority: Major > Attachments: image-2024-11-27-16-23-22-995.png > > > Currently, FlinkCDC can correctly synchronize the same time type (where the > type indicates whether the time zone is included or not), but time offsets > can occur when synchronizing between fields of different time types. For > example, when synchronizing the field DATETIME (without time zone) in MySQL > to the field TIMESTAMPTZ (with time zone) in Iceberg, there is an 8-hour > offset after synchronization when the time in mysql represents Beijing time. > This kind of synchronization in different time type fields is very common in > practical applications, however, the time offset will be troublesome for > business. Therefore, Flink CDC's support for the conversion of different time > types will avoid the time offset and help improve the data consistency and > accuracy of synchronization. > > !image-2024-11-27-16-23-22-995.png|width=1004,height=375! -- This message was sent by Atlassian Jira (v8.20.10#820010)