FAQ-实时同步任务报错：xxx cannot be cast to xxx

问题描述/异常栈

任务报错：xxx cannot be cast to xxx 例如 org.apache.flink.table.data.TimestampData cannot be cast to org.apache.flink.table.data.stringData

发现版本

任何版本

解决方案

排查源表和目标表所有字段类型，尤其是自定义表达式，例如cast（timestamp as string）timestamp,保证前后字段类型一致。 一此类问题一般都可以通过修改去向表字段类型或使用flink函数强转来源表数据解决。

当目标表为amoro时，在创建传输任务时，可先选择去向类型为Hive，使用快速建表功能创建与来源表结构匹配的Hive表，然后再使用Amoro的Upgrade功能将该表升级为Amoro表。最后再切换去向类型为Amoro，选择刚刚升级的表。

问题原因

实时传输任务类型转换时，是 来源物理类型->来源Flink类型->去向Flink类型->去向物理类型，报类型转换失败指的是其中的来源Flink类型->去向Flink类型，源端和目标端字段类型不一致，就会导致FLink内部无法进行类型转换。

作者：楚展航