开发者社区 问答 正文

Flink报错Table '****' is a partitioned table, but...

已解决

Flink报错Table '****' is a partitioned table, but the underlying DynamicTableSink doesn't implement the SupportsPartitioning interface.

展开
收起
提个问题 2024-06-09 16:03:36 100 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    在DDL里写partioned by 语法需要对应的connector sink 实现SupportsPartitioning 接口,目前holo connector是没有支持的,所以不支持这个语法。用户参考的 DDL 语法中 [] 括号是表示可选的含义,不是所有connector都支持的含义
    2024-06-09 16:03:37 举报
    赞同 1 评论

    评论

    全部评论 (0)

    登录后可评论
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等