开发者社区问答正文

Flink报错:org.apache.flink.table.api.ValidationEx...

已解决

Flink报错:org.apache.flink.table.api.ValidationException: SQL validation failed. Unable to create a sink for writing table 'xxx'. The cause is following: Unsupported options found for 'sls'.

展开

收起

提个问题 2024-06-02 11:04:07 202 版权

1 条回答

写回答

取消提交回答

社区答人

开发者社区问答官方账号

官方回答

采纳回答

【报错详情】
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options found for 'sls'. Unsupported options: xxx Supported options: accessid accesskey baseretrybackofftimems batchgetsize connector consumergroup directmode disabledirectmode endpoint endtime exitafterfinish failonerror fallback_to_old flushintervalms iothreadnum logstore maxblocktimems maxretries maxretrybackofftimems maxretrytimes nullreplacestr partitionfield project property-version sourcefield starttime starttimems stoptime timefield timezone topicfield
【报错原因】
SLS对应的with参数出现不支持的with参数xxx，或可能写错参数名称导致该异常出现。
【解决方案】
根据官网文档DDL数据定义语句文档进行检查，是否支持对应的参数，或参数名称写的有误。

2024-06-02 11:04:08

赞同展开评论