Re: Re: flink waterMark 相关问题

Tue, 12 Jan 2021 18:26:17 -0800 

ok，明白了

anonnius <[email protected]> 于2021年1月13日周三 上午10:20写道：

> 在 StreamExecutionEnvironmennt的方法<br/>@PublicEvolving<br/>       public
> void setStreamTimeCharacteristic(TimeCharacteristic characteristic) {<br/>
>              this.timeCharacteristic =
> Preconditions.checkNotNull(characteristic);<br/>              if
> (characteristic == TimeCharacteristic.ProcessingTime) {<br/>
>  getConfig().setAutoWatermarkInterval(0);<br/>           } else {<br/>
>              getConfig().setAutoWatermarkInterval(200);<br/>
>  }<br/>  }
> 在 2021-01-13 10:09:54，"张锴" <[email protected]> 写道：
> >我从ExecutionConfig找到了，private long autoWatermarkInterval =
> >0，并不是200毫秒，这个代表一个时间戳就代表一个watermark是吗
> >
> >Ball's Holy <[email protected]> 于2021年1月13日周三 上午9:42写道：
> >
> >> hi&nbsp;张锴,
> >> 如果我没记错的话，默认时间间隔是200毫秒，具体设置细节可以看flink.api.common.ExecutionConfig
> >> 对应的属性autoWatermarkInterval
> >>
> >>
> >>
> >>
> >> ------------------&nbsp;原始邮件&nbsp;------------------
> >> 发件人: "anonnius"<[email protected]&gt;;
> >> 发送时间: 2021年1月13日(星期三) 上午9:19
> >> 收件人: "user-zh"<[email protected]&gt;;
> >> 主题: Re:flink waterMark 相关问题
> >>
> >>
> >>
> >> 可以看一下 ExecutionConfig这个类
> >> 在 2021-01-12 17:55:47，"张锴" <[email protected]&gt; 写道：
> >> &gt;hi，我使用的flink版本是1.10，我想问一下watermark的默认时间间隔是多少，以及所对应的源码位置在哪里，我并没有找到。
>

回复