Flink报错：Incompatible types for sink column 'xxx' a

【报错详情】

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建表语句定义的字段类型，顺序及类型均需保持一致。