ersion为1.4所创建的表吗，我发现使用1.4.3的版本，也是可以正常使用的。是不是说明pk在1.4和1.4.3两个版本上都是生效的？
> 再次感谢。
>
>
> Best
> Xiao Cai
>
> 发送自 Windows 10 版邮件应用
>
> 发件人: Jark Wu
> 发送时间: 2020年8月14日 23:23
> 收件人: user-zh
> 主题: Re: HBase Sink报错：UpsertStreamTableSink requires that Table has a full
&g
: user-zh
主题: Re: HBase Sink报错：UpsertStreamTableSink requires that Table has a full
primary keys
PK 的问题在1.11 已经解决了，你可以用下1.11 提供的新版 hbase connector，可以在 DDL 上指定 PK，所以 query
推导不出 PK 也不会报错了。
see more:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/hbase.html
Best
PK 的问题在1.11 已经解决了，你可以用下1.11 提供的新版 hbase connector，可以在 DDL 上指定 PK，所以 query
推导不出 PK 也不会报错了。
see more:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/hbase.html
Best,
Jark
On Thu, 13 Aug 2020 at 14:27, xiao cai wrote:
> Hi All:
> 使用flink-sql写入hbase sink时报错：
Hi All:
使用flink-sql写入hbase sink时报错：
UpsertStreamTableSink requires that Table has a full primary keys if it is
updated.
我共创建了4张表，1张kafka source表，3张hbase 维表，1张hbase sink表
kafka source表与hbase 维表left join后的结果insert到hbase sink表中：
sql如下：
create table user_click_source(
`id` bigint,
`name` varchar,
