Re:Re: flink waterMark 相关问题

Tue, 12 Jan 2021 18:13:51 -0800 

在 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的默认时间间隔是多少，以及所对应的源码位置在哪里，我并没有找到。

回复