开发者社区 问答 正文

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

已解决

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'.

展开
收起
阿里云服务支持 2022-12-20 14:19:57 1826 分享 版权
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数据定义语句文档进行检查,是否支持对应的参数,或参数名称写的有误。

    2022-12-20 14:27:51
    赞同 展开评论