flink cdc 2.2.0 flink 1.13.6有发现数据丢失的情况 怎么解决？

If you are using Flink-CDC 2.3 to synchronize data from a source table with a "datetime" column type to Apache Hive, and the column type is changed to "long" in Hive, there are a few solutions you can consider to resolve the issue: 1 Cast the data: In Hive, you can cast the "long" data back to the "datetime" type using the cast() function in a SELECT statement. For example: SELECT cast(column_name as timestamp) as column_name ... 2 Modify the Flink-CDC configuration: You can modify the Flink-CDC configuration to explicitly specify the target column type in Hive as "datetime". This can be done by setting the "target.column.types" property in the Flink-CDC configuration file. 3 Use a data conversion tool: You can use a data conversion tool, such as Apache NiFi, to convert the data from "long" to "datetime" as it is being loaded into Hive. It is recommended to test any changes to the configuration or data conversion process thoroughly before implementing in a production environment to ensure that the data is correctly synchronized between the source and target systems.——该回答整理自钉群“Flink CDC 社区”