Re: 广播状态是否可以设置ttl过期时间

Thu, 07 Nov 2019 04:08:47 -0800 

1.8.0之前，ttl保证的是在ttl到达之前，数据不会清空，但是不保证ttl到达之后，数据一定清空。1.8.0之后提供了更完善的功能，可以看一下这个文章：https://flink.apache.org/2019/05/19/state-ttl.html
 <https://flink.apache.org/2019/05/19/state-ttl.html>
> 在 2019年11月7日，下午3:06，Yang Peng <[email protected]> 写道：
> 
> 
> 
> ---------- Forwarded message ---------
> 发件人： yangpengklf007 <[email protected] 
> <mailto:[email protected]>>
> Date: 2019年11月7日周四 下午3:00
> Subject: 广播状态是否可以设置ttl过期时间
> To: [email protected] <mailto:[email protected]> 
> <[email protected] <mailto:[email protected]>>
> 
> 
> 如下图是我设置得测试代码：在类中定义一个mapstatedesc，然后在processBroadcastElement方法中获取广播数据放入到state中 
> 设置ttl是1s然后让程序sleep10s 
> 再次从state中获取数据发现数据依旧存在，是广播状态不支持ttl还是我设置的方式不对，有用过的同学吗，还望不吝赐教 谢谢
> 
> 
>                               
> yangpengklf007
> [email protected]
>  
> <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=yangpengklf007&uid=yangpengklf007%40gmail.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyelogo%2FdefaultAvatar.png&items=%5B%22yangpengklf007%40gmail.com%22%5D>
> 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制

回复