普通表join版本表，怎么得到append表

[杨光跃 <ya...@163.com>]

大佬们，请教个问题，
insert into sink_2 
select a.`time`,c.cust,b.mobile
from case2_TOPIC_A a
left join card_data b on a.card = b.card
left join view_new_card_info c on a.card = c.card;




case2_TOPIC_A  是一个普通表，view_new_card_info 是维表， 我要插入的 sink_2 其实应该是一个apped表。  为什么提交的时候要求 
please declare primary key for sink table when query contains update/delete record.


我这个只需要追加就可以了吧，该怎么处理呢？


| |
杨光跃
|
|
yangguangyuemail@163.com
|
签名由网易邮箱大师定制

回复：普通表join版本表，怎么得到append表

[silence <sl...@aliyun.com.INVALID>]

目前interval join和维表的时态join不会进行回撤，其他场景会产生回撤数据


------------------------------------------------------------------
发件人：杨光跃 <ya...@163.com>
发送时间：2021年6月30日(星期三) 17:47
收件人：user-zh@flink.apache.org <us...@flink.apache.org>
主　题：普通表join版本表，怎么得到append表

大佬们，请教个问题，
insert into sink_2 
select a.`time`,c.cust,b.mobile
from case2_TOPIC_A a
left join card_data b on a.card = b.card
left join view_new_card_info c on a.card = c.card;




case2_TOPIC_A  是一个普通表，view_new_card_info 是维表， 我要插入的 sink_2 其实应该是一个apped表。  为什么提交的时候要求 
please declare primary key for sink table when query contains update/delete record.


我这个只需要追加就可以了吧，该怎么处理呢？


| |
杨光跃
|
|
yangguangyuemail@163.com
|
签名由网易邮箱大师定制