[FLINK-15407] Add document to explain how to write a table with PK

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Fix Version/s: 1.11.0
• Component/s: Documentation, Table SQL / API
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 26/Dec/19 12:43
• Updated: 24/Feb/20 04:13
• Resolved: 24/Feb/20 04:13

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.

Issue Links

• relates to: FLINK-14567 Aggregate query with more than two group fields can't be write into HBase sink