Re: Re: flink waterMark 相关问题

Tue, 12 Jan 2021 18:44:46 -0800 

private long autoWatermarkInterval = 200;

/**
 * Interval in milliseconds for sending latency tracking marks from
the sources to the sinks.
 */


张锴 <zk357794...@gmail.com> 于2021年1月13日周三 上午10:26写道：

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

回复