在使用interval join的时候有一些疑问,希望大家能够帮忙解答一下 https://pic.imgdb.cn/item/62c5015b5be16ec74ac2b23f.png 官方文档中说会从两个流中的 timestamp 中取最大值,看了下源码确实是这样 https://pic.imgdb.cn/item/62c51e8b5be16ec74ae22880.png 我的问题是: 1.这里的timestamp和watermark有什么区别? 2.interval join中watermark是怎么计算的?两个流取最大的timestamp之后,watermark跟这个最大的timestamp是否有某种联系
- Flink interval join 水印疑问 lxk
- Re: Flink interval join 水印疑问 yidan zhao
- Re:Re: Flink interval join 水印疑问 lxk
- Re: Re: Flink interval join 水印疑问 yidan zhao