开发者社区> 问答> 正文

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 79 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    在DDL里写partioned by 语法需要对应的connector sink 实现SupportsPartitioning 接口,目前holo connector是没有支持的,所以不支持这个语法。用户参考的 DDL 语法中 [] 括号是表示可选的含义,不是所有connector都支持的含义
    2024-06-09 16:03:37
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载