Re: 回复: 使用sql时候,设置了idle过期时间,但是状态还是一直变大

2020-05-17 文章 LakeShen
,应该很快就会过期,kafka数据流量的话每秒2-5M > > > --原始邮件-- > 发件人:"刘大龙" 发送时间:2020年5月17日(星期天) 晚上10:14 > 收件人:"user-zh" > 主题:Re: 回复: 使用sql时候,设置了idle过期时间,但是状态还是一直变大 > > > > Hi, > 你的状态过期时间设置的是多久?对于普通的group by > agg算子,目前使用的是定时器方式实现过期状态的清

Re: 回复: 使用sql时候,设置了idle过期时间,但是状态还是一直变大

2020-05-17 文章 刘大龙
Hi, 你的状态过期时间设置的是多久?对于普通的group by agg算子,目前使用的是定时器方式实现过期状态的清理,精确的过期时间是状态最后更新时间加上你设置的最小idle,如果状态在一直更新,是不会过期的;另外你的Kafka中的数据量有多大?比如每秒大概有多少条数据?你可以试试把过期时间设置的短一点,观察一下状态是否能比较稳定的不增大 > -原始邮件- > 发件人: claylin <1012539...@qq.com> > 发送时间: 2020-05-17 17:41:13 (星期日) > 收件人: user-zh > 抄送: > 主题: 回复: