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/

回复