flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yang Peng <yangpengklf...@gmail.com>
Subject Fwd: 广播状态是否可以设置ttl过期时间
Date Thu, 07 Nov 2019 07:06:51 GMT
---------- Forwarded message ---------
发件人: yangpengklf007 <yangpengklf007@gmail.com>
Date: 2019年11月7日周四 下午3:00
Subject: 广播状态是否可以设置ttl过期时间
To: user-zh@flink.apache.org <user-zh@flink.apache.org>


如下图是我设置得测试代码:在类中定义一个mapstatedesc,然后在processBroadcastElement方法中获取广播数据放入到state中
设置ttl是1s然后让程序sleep10s
再次从state中获取数据发现数据依旧存在,是广播状态不支持ttl还是我设置的方式不对,有用过的同学吗,还望不吝赐教
谢谢
yangpengklf007
yangpengklf007@gmail.com
<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> 定制
Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message