Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Won't Fix
-
None
-
None
Description
I have had several user problems:
Why is an error reported when writing the upsertsink: TableException: UpsertStreamTableSink requires that Table has a full primary keys if it is updated.
Users are confused.
I think we can consider writing a document to describe it.
User need careful like:
insert into result_table select pk1, if(pk2 is null, '', pk2) as pk2, count(*), sum(f3) from source group by pk1, pk2;
This will failed.
insert into result_table select pk1, pk2, count(*), sum(f1) from (select pk1, if(pk2 is null, '', pk2) as pk2, f1 from source) group by pk1, pk2;
This can work.
Attachments
Issue Links
- relates to
-
FLINK-14567 Aggregate query with more than two group fields can't be write into HBase sink
- Closed