1: Interval Join doesn't support consuming update and delete changes 是因为A或B是一个update stream
2: Interval Join 的临时数据是放在buffer中,当wtm超过边界时间就会清理掉 buffer也就join不到了。所以 statettl无法控制A流的缓存数据。 延迟问题:所以如果wtm不更新,A流的数据不会被清理因为不受statettl控制 乱序问题:如果B流的旧时间小于 watermark就join不上 以上是个人理解、、 -- Sent from: http://apache-flink.147419.n8.nabble.com/