Flink-间隔联结
- 间隔联结只支持事件时间
- 间隔联结如果遇到迟到数据，则会关联不上，比如来了一个5秒的数据，它可以关联前2秒的数据，后3秒的数据，就是可以关联3秒到8秒的数据，然后又来了一个6秒的数据，可以关联4秒到9秒的数据，那么3秒的数据，就永远不会被关联到了，就可以删除了，然后又来了一个迟到数据，比如4秒的数据，可以关联2秒到7秒的数据，但是3秒的数据已经被删除了，所以就关联不上了。对于这种情况，解决办法就是，使用回撤流，比如left join，left join可以设置状态过期时间，这个时间是系统时间，比如我们设置过期时间是5分钟，那么A流的3秒的数据，可以和B流的4秒(迟到数据)的数据关联上，就解决了这个问题。