Thank you , Jark . I have added the primary key in my flink sql before ,
and it throwed the * Primary key and unique key are not supported yet. *Now
I know it ,thank you sincerely to reply me .
Best wishes,
LakeShen
Jark Wu 于2019年9月12日周四 下午3:15写道:
> Hi Lake,
>
> This is not a problem of HBas
Hi Lake,
This is not a problem of HBaseUpsertTableSink.
This is because the query loses primary key (e.g. concat(key1, key2) will
lose the primary key information [key1, key2] currently.),
but the validation of inserting checks the upsert query should have a
primary key. That’s why the exception i