| flink版本 | 异常 | 解决 | 推荐链接 | 备注 | 疑问 |
| 1.10.0 |
Exception in thread "main" org.apache.flink.table.api.TableException: UpsertStreamTableSink requires that Table has a full primary keys if it is updated. |
报错说表缺主键,然后我在DDL中声明了主键,又报不支持主键。这不耍我么? 原因:其实不是要我去声明主键,而是blink planner在DDL里面找不到主键。解决措施如下,即select外层再套一层select。来自 <http://apache-flink.147419.n8.nabble.com/> |
建议 Apache Flink 中文用户邮件列表
|
||