开发者社区> 问答> 正文

Flink报错:Incompatible types for sink column 'xxx...

已解决

Flink报错:Incompatible types for sink column 'xxx' at position x.

展开
收起
提个问题! 2024-06-04 15:07:16 34 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    【报错详情】
    org.apache.flink.table.api.ValidationException: SQL validation failed. Column types of query result and sink for 'vvp.default.xxx' do not match. Cause: Incompatible types for sink column 'xxx' at position x. Query schema: [xxx: xxx, xxx: xxx] Sink schema: [xxx: xxx, xxx: xxx] at org.apache.flink.table.sqlserver.utils.FormatValidatorExceptionUtils.newValidationException(FormatValidatorExceptionUtils.java:41)
    【报错原因】
    DML select 的表字段类型 与 DDL 建表语句定义的字段类型不匹配。
    【解决方案】
    位置在x位置存在字段类型不匹配,请检查DML select 的表字段类型与DDL建表语句定义的字段类型,顺序及类型均需保持一致。
    2024-06-04 15:07:17
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载