目前interval join和维表的时态join不会进行回撤，其他场景会产生回撤数据
--
发件人：杨光跃
发送时间：2021年6月30日(星期三) 17:47
收件人：user-zh@flink.apache.org
主 题：普通表join版本表，怎么得到append表
大佬们，请教个问题，
insert into sink_2
select a.`time`,c.cust,b.mobile
from case2_TOPIC_A a
left
大佬们，请教个问题，
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
大佬，再请教个问题，
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
收到了，谢谢。
在sql-client里面执行 ： set table.exec.source.idle-timeout = 10s;
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月30日 15:36，silence 写道：
可参考
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/config/#table-exec-source-idle-timeout
可参考
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/config/#table-exec-source-idle-timeout
--
发件人：杨光跃
发送时间：2021年6月30日(星期三) 10:54
收件人：user-zh@flink.apache.org
主 题：flink sql 空闲数据源场景如何配置
在代码中可以通过
