我从ExecutionConfig找到了,private long autoWatermarkInterval = 0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
Ball's Holy <873925...@qq.com> 于2021年1月13日周三 上午9:42写道: > hi 张锴, > 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig > 对应的属性autoWatermarkInterval > > > > > ------------------ 原始邮件 ------------------ > 发件人: "anonnius"<anonn...@126.com>; > 发送时间: 2021年1月13日(星期三) 上午9:19 > 收件人: "user-zh"<user-zh@flink.apache.org>; > 主题: Re:flink waterMark 相关问题 > > > > 可以看一下 ExecutionConfig这个类 > 在 2021-01-12 17:55:47,"张锴" <zk357794...@gmail.com> 写道: > >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。