问题一:实时计算Flink报错Only a single 'INSERT INTO' is supported
实时计算Flink报错Only a single 'INSERT INTO' is supported
参考答案:
可参考QA:报错:Only a single 'INSERT INTO' is supported
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/475551?spm=a2c6h.13066369.question.31.6f064d5chl4fJq
问题二:实时计算Flink报错DELETE command denied to user 'userName'@'...' for table 'table_name'
实时计算Flink报错DELETE command denied to user 'userName'@'...' for table 'table_name'
参考答案:
可参考QA:报错:DELETE command denied to user 'userName'@'...' for table 'table_name'
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/475318?spm=a2c6h.13066369.question.34.6f064d5c7dUZBT
问题三:Flink 报错:Caused by: org.apache.flink.table.api.ValidationException: Column types of query result and sink for 'vvp.default.xxx' do not match.
Flink 报错:Caused by: org.apache.flink.table.api.ValidationException: Column types of query result and sink for 'vvp.default.xxx' do not match.
参考答案:
【报错详情】
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定义的表字段数,需保持一致。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476362?spm=a2c6h.13066369.question.33.6f064d5czGRnTo
问题四:实时计算Flink报错The primary key is necessary when enable 'Key: 'scan.incremental.snapshot.enabled' , default: true (fallback keys: [])' to 'true'
实时计算Flink报错The primary key is necessary when enable 'Key: 'scan.incremental.snapshot.enabled' , default: true (fallback keys: [])' to 'true'
参考答案:
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/475553?spm=a2c6h.13066369.question.34.6f064d5cUggR9h
问题五:Flink报错:Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6)
Flink报错:Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6)
参考答案:
【报错详情】
Caused by: org.apache.flink.table.api.ValidationException: Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6) at org.apache.flink.table.catalog.DefaultSchemaResolver.validateTimeColumn(DefaultSchemaResolver.java:263) at org.apache.flink.table.catalog.DefaultSchemaResolver.resolveWatermarkSpecs(DefaultSchemaResolver.java:218)
【报错原因】
watermark接收的字段,精度超过了TIMESTAMP(3)。
【解决方案】
将字段类型修改为TIMESTAMP(3)精度以内,或使用TO_TIMESTAMP函数将该字段类型进行转换。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476368?spm=a2c6h.13066369.question.35.6f064d5caaDqS5