Hi, > 在 2020年12月7日，16:41，爱成绕指柔 <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
