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
Hi community , when I create the hbase sink table in my flink ddl sql
,just like this:
*create table sink_hbase_table(rowkey VARCHAR,cf
row(kdt_it_count bigint )) with (xx);*
and I run my flink task , it throws the exception like this :
*Up
