Hi, 你是不是没有订阅flink的用户邮件列表，所以有些邮件你看不到。 你可以发送任意内容的邮件到user-zh-subscr...@flink.apache.org <mailto:user-zh-subscr...@flink.apache.org> 即可订阅用户邮件列表，订阅后邮件列表里大家的提问和回答你都可以看见了。
[1] https://flink.apache.org/zh/community.html > 在 2020年12月7日，16:50，Leonard Xu <xbjt...@gmail.com> 写道： > > Hi, > >> 在 2020年12月7日，16:41，爱成绕指柔 <1194803...@qq.com <mailto:1194803...@qq.com>> 写道： >> >> Exception in thread "main" org.apache.flink.table.api.TableException: >> UpsertStreamTableSink requires that Table has a full primary keys if it is >> updated. > > 这个错误是在query 没法推断出主键，而 hbase sink 是一个upsert sink, 需要PK来实现upsert语义。 > > 在1.10的版本的话，你可以试着改写下SQL，比如在query的外层再加一层group by rowkey， 这种方式性能比较差。 > 建议直接升级1.11.x版本，在1.11.0之后flink > 支持定义PK，你这个case只需要在hbase表的DDL上声明rowkey为PK即可，不再需要通过query推断PK。 > > 祝好， > Leonard
