我们也遇到过类似场景。 如果你的数据里面有事件时间，可以写个udf来判断下，如果事件时间-当前时间 小于某个阈值，可以sleep一下。 如果没有事件时间，那就不太好直接搞了，我们是自己搞了一个延迟维表，就是保证每条数据进到维表join算子后等固定时间后再去join。
admin <[email protected]> 于2020年7月3日周五 下午5:54写道： > Hi，all > 我们有这样一个场景，双流join，一个快流，一个慢流，想让快流等一段时间，目的是能提高join的命中率。 > FLink sql有什么方案实现吗？ > > 感谢您的回复 -- Best, Benchao Li
