You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Ball's Holy <87...@qq.com> on 2021/01/13 01:41:38 UTC
回复:flink waterMark 相关问题
hi 张锴, 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig 对应的属性autoWatermarkInterval
------------------ 原始邮件 ------------------
发件人: "anonnius"<anonnius@126.com>;
发送时间: 2021年1月13日(星期三) 上午9:19
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re:flink waterMark 相关问题
可以看一下 ExecutionConfig这个类
在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
>hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
Re: flink waterMark 相关问题
Posted by 张锴 <zk...@gmail.com>.
ok,谢谢你
Ball's Holy <87...@qq.com> 于2021年1月13日周三 上午9:42写道:
> hi 张锴,
> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> 对应的属性autoWatermarkInterval
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "anonnius"<anonnius@126.com>;
> 发送时间: 2021年1月13日(星期三) 上午9:19
> 收件人: "user-zh"<user-zh@flink.apache.org>;
> 主题: Re:flink waterMark 相关问题
>
>
>
> 可以看一下 ExecutionConfig这个类
> 在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
> >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
回复: flink waterMark 相关问题
Posted by Ball's Holy <87...@qq.com>.
master分支应该是200毫秒,1.10版本的话参考这个参数默认值。代表生成watermark时间间隔
------------------ 原始邮件 ------------------
发件人: "张锴"<zk357794239@gmail.com>;
发送时间: 2021年1月13日(星期三) 上午10:09
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: flink waterMark 相关问题
我从ExecutionConfig找到了,private long autoWatermarkInterval =
0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
Ball's Holy <873925389@qq.com> 于2021年1月13日周三 上午9:42写道:
> hi&nbsp;张锴,
> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> 对应的属性autoWatermarkInterval
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人: "anonnius"<anonnius@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,"张锴" <zk357794239@gmail.com&gt; 写道:
> &gt;hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
Re: Re: flink waterMark 相关问题
Posted by Px New <15...@gmail.com>.
private long autoWatermarkInterval = 200;
/**
* Interval in milliseconds for sending latency tracking marks from
the sources to the sinks.
*/
张锴 <zk...@gmail.com> 于2021年1月13日周三 上午10:26写道:
> ok,明白了
>
> anonnius <an...@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,"张锴" <zk...@gmail.com> 写道:
> > >我从ExecutionConfig找到了,private long autoWatermarkInterval =
> > >0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
> > >
> > >Ball's Holy <87...@qq.com> 于2021年1月13日周三 上午9:42写道:
> > >
> > >> hi 张锴,
> > >> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> > >> 对应的属性autoWatermarkInterval
> > >>
> > >>
> > >>
> > >>
> > >> ------------------ 原始邮件 ------------------
> > >> 发件人: "anonnius"<anonnius@126.com>;
> > >> 发送时间: 2021年1月13日(星期三) 上午9:19
> > >> 收件人: "user-zh"<user-zh@flink.apache.org>;
> > >> 主题: Re:flink waterMark 相关问题
> > >>
> > >>
> > >>
> > >> 可以看一下 ExecutionConfig这个类
> > >> 在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
> > >> >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
> >
>
Re: Re: flink waterMark 相关问题
Posted by 张锴 <zk...@gmail.com>.
ok,明白了
anonnius <an...@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,"张锴" <zk...@gmail.com> 写道:
> >我从ExecutionConfig找到了,private long autoWatermarkInterval =
> >0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
> >
> >Ball's Holy <87...@qq.com> 于2021年1月13日周三 上午9:42写道:
> >
> >> hi 张锴,
> >> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> >> 对应的属性autoWatermarkInterval
> >>
> >>
> >>
> >>
> >> ------------------ 原始邮件 ------------------
> >> 发件人: "anonnius"<anonnius@126.com>;
> >> 发送时间: 2021年1月13日(星期三) 上午9:19
> >> 收件人: "user-zh"<user-zh@flink.apache.org>;
> >> 主题: Re:flink waterMark 相关问题
> >>
> >>
> >>
> >> 可以看一下 ExecutionConfig这个类
> >> 在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
> >> >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
>
Re:Re: flink waterMark 相关问题
Posted by anonnius <an...@126.com>.
在 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,"张锴" <zk...@gmail.com> 写道:
>我从ExecutionConfig找到了,private long autoWatermarkInterval =
>0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
>
>Ball's Holy <87...@qq.com> 于2021年1月13日周三 上午9:42写道:
>
>> hi 张锴,
>> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
>> 对应的属性autoWatermarkInterval
>>
>>
>>
>>
>> ------------------ 原始邮件 ------------------
>> 发件人: "anonnius"<anonnius@126.com>;
>> 发送时间: 2021年1月13日(星期三) 上午9:19
>> 收件人: "user-zh"<user-zh@flink.apache.org>;
>> 主题: Re:flink waterMark 相关问题
>>
>>
>>
>> 可以看一下 ExecutionConfig这个类
>> 在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
>> >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
回复: flink waterMark 相关问题
Posted by Ball's Holy <87...@qq.com>.
master分支应该是200毫秒,1.10版本的话参考这个参数默认值。代表生成watermark时间间隔
------------------ 原始邮件 ------------------
发件人: "user-zh" <zk357794239@gmail.com>;
发送时间: 2021年1月13日(星期三) 上午10:09
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: flink waterMark 相关问题
我从ExecutionConfig找到了,private long autoWatermarkInterval =
0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
Ball's Holy <873925389@qq.com> 于2021年1月13日周三 上午9:42写道:
> hi&nbsp;张锴,
> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> 对应的属性autoWatermarkInterval
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人: "anonnius"<anonnius@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,"张锴" <zk357794239@gmail.com&gt; 写道:
> &gt;hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
Re: flink waterMark 相关问题
Posted by 张锴 <zk...@gmail.com>.
我从ExecutionConfig找到了,private long autoWatermarkInterval =
0,并不是200毫秒,这个代表一个时间戳就代表一个watermark是吗
Ball's Holy <87...@qq.com> 于2021年1月13日周三 上午9:42写道:
> hi 张锴,
> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
> 对应的属性autoWatermarkInterval
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "anonnius"<anonnius@126.com>;
> 发送时间: 2021年1月13日(星期三) 上午9:19
> 收件人: "user-zh"<user-zh@flink.apache.org>;
> 主题: Re:flink waterMark 相关问题
>
>
>
> 可以看一下 ExecutionConfig这个类
> 在 2021-01-12 17:55:47,"张锴" <zk357794239@gmail.com> 写道:
> >hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。