You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "tiantingting5435@163.com" <ti...@163.com> on 2020/07/03 06:42:03 UTC

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

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，tiantingting5435@163.com 写道：
> 
> MD5(real_income_no) as rowkey,