奥,对,还有一种思路。如果你的source的mq支持延迟消息,这个应该就不需要Flink做什么了,直接用mq的延迟消息就可以了。
admin <[email protected]> 于2020年7月3日周五 下午5:54写道: > Hi,all > 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。 > FLink sql有什么方案实现吗? > > 感谢您的回复 -- Best, Benchao Li
奥,对,还有一种思路。如果你的source的mq支持延迟消息,这个应该就不需要Flink做什么了,直接用mq的延迟消息就可以了。
admin <[email protected]> 于2020年7月3日周五 下午5:54写道: > Hi,all > 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。 > FLink sql有什么方案实现吗? > > 感谢您的回复 -- Best, Benchao Li