开发者社区> 问答> 正文

flink sql ddl 不支持primary key怎么办呢?

我看源码在将sqlNode转换CreateTableOperator[1]时,还是不支持primary key配置,但是sql parser是已经能够解析,请问下为何不放开这个限制。

https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java#L178*来自志愿者整理的FLINK邮件归档

展开
收起
玛丽莲梦嘉 2021-12-03 18:31:48 1230 0
1 条回答
写回答
取消 提交回答
  • 是的,现在是不支持,老的sink没有使用这个primary key来做upsert,但是在1.11里新的sink接口会打通DDL的primary key的。[1]

    [1]https://issues.apache.org/jira/browse/FLINK-17030*来自志愿者整理的FLINK邮件归档

    2021-12-03 18:57:03
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 覃立辉 立即下载
Flink CDC Meetup PPT - 孙家宝 立即下载
Flink CDC Meetup PPT - 徐榜江 立即下载