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 张锴 <zk...@gmail.com> on 2021/01/12 09:55:47 UTC
flink waterMark 相关问题
hi，我使用的flink版本是1.10，我想问一下watermark的默认时间间隔是多少，以及所对应的源码位置在哪里，我并没有找到。
Re: flink waterMark 相关问题
Posted by 张锴 <zk...@gmail.com>.
谢谢你
anonnius <an...@126.com> 于2021年1月13日周三 上午9:19写道：
> 可以看一下 ExecutionConfig这个类
> 在 2021-01-12 17:55:47，"张锴" <zk...@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的默认时间间隔是多少，以及所对应的源码位置在哪里，我并没有找到。
回复：flink waterMark 相关问题
Posted by Ball's Holy <87...@qq.com>.
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 anonnius <an...@126.com>.
可以看一下 ExecutionConfig这个类
在 2021-01-12 17:55:47，"张锴" <zk...@gmail.com> 写道：
>hi，我使用的flink版本是1.10，我想问一下watermark的默认时间间隔是多少，以及所对应的源码位置在哪里，我并没有找到。