Re:flink双流join如何确保数据不丢失

[Smile@LETTers]

用 left join 或者 full join？这样的话关联不上的数据在区间结束的时候也会被输出，对侧表的字段用 null 填充。<br/>目前 
DataStream API 里面 Interval Join 还不支持 outer join，不过 Table API/SQL 
是支持的，参考[1]。<br/><br/>[1]. 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html#joins
在 2021-02-08 19:05:56，"lxk7...@163.com" <lxk7...@163.com> 写道：
>
>目前在使用flink进行双流join，多是使用interval join,根据经验值给定时间间隔，那么该如何保证数据不丢失呢？
>如果数据晚于这个时间间隔，那么数据就被丢弃了，而我做的是关于订单的数据，这是不被允许的。
>
>
>lxk7...@163.com