Re: flink1.10 用flinksql 写hbase，报错：UpsertStreamTableSink requires that Table has a full primary keys if it is updated.

[Leonard Xu]

Hello,

你试下 MD5(real_income_no) as rowkey 放在query的里层，最外层的group by直接用 rowkey试下， Flink 
1.11 之后支持在 table里声明 PK, 1.11后就不用推导了。

祝好，
Leonard Xu


> 在 2020年7月1日，13:51，tiantingting5...@163.com 写道：
> 
> MD5(real_income_no) as rowkey,