问题一： Interval Join doesn't support consuming update and delete changes是因为输入A或者B是一个更新流 问题二：interval join使用buffer来缓存A和B的数据，没有放在state里，只有在watermark超过下边界会触发onEventtime清理 buffer。 延迟问题：没有类似statettl的配置，interval join不受statettl控制清除状态 乱序问题：如果 B的数据时间小于 watermark则匹配不到，一切是跟watermmark相关
以上个人看源码理解的。希望有帮助 -- Sent from: http://apache-flink.147419.n8.nabble.com/
