Flink 报错:Caused by: org.apache.flink.table.api.Val

【报错详情】

org.apache.flink.table.api.ValidationException: SQL validation failed. Column types of query result and sink for 'vvp.default.xxx' do not match. Cause: Different number of columns. Query schema: [xxx: xxx, xxx: xxx, xxx: xxx...] Sink schema: [xxx: xxx, xxx: xxx...] at org.apache.flink.table.sqlserver.utils.FormatValidatorExceptionUtils.newValidationException(FormatValidatorExceptionUtils.java:41)

【报错原因】

DML查询的表字段个数与DDL定义的表字段个数不符。

【解决方案】

请检查DML查询的表字段个数与DDL定义的表字段数，需保持一致。