Re: Re: 回复： BLinkPlanner sql join状态清理

Hi, MiniBatch Agg目前没有实现State TTl，我提了个PR修复这个问题，参考https://github.com/apache/flink/pull/11830 @Jark，辛苦有空时帮忙reveiw一下代码，这个问题越来越多用户用户遇到了。 > -原始邮件- > 发件人: "刘建刚" > 发送时间: 2020-09-29 18:27:47 (星期二) > 收件人: user-zh > 抄送: > 主题: Re: 回复： BLinkPlanner sql join状态清理 &g

Re: 回复： BLinkPlanner sql join状态清理

miniBatch下是无法ttl的，这个是修复方案：https://github.com/apache/flink/pull/11830 Benchao Li 于2020年9月29日周二 下午5:18写道： > Hi Ericliuk, > > 这应该是实现的bug，你可以去社区建一个issue描述下这个问题。 > 有时间的话也可以帮忙修复一下，没有时间社区也会有其他小伙伴帮忙来修复的~ > > Ericliuk 于2020年9月29日周二 下午4:59写道： > > >

Re: 回复： BLinkPlanner sql join状态清理

Hi Ericliuk, 这应该是实现的bug，你可以去社区建一个issue描述下这个问题。 有时间的话也可以帮忙修复一下，没有时间社区也会有其他小伙伴帮忙来修复的~ Ericliuk 于2020年9月29日周二 下午4:59写道： > 我最近也遇到了这个问题，看了下，blink，并且配置minibatch优化后就会不使用IdleStateRetention相关配置了。 > < > http://apache-flink.147419.n8.nabble.com/file/t491/Xnip2020-09-29_16-55-32.png> > > > 不太清楚为什么用了mini

Re: 回复： BLinkPlanner sql join状态清理

我最近也遇到了这个问题，看了下，blink，并且配置minibatch优化后就会不使用IdleStateRetention相关配置了。 不太清楚为什么用了mini batch就没读取这个配置。 一个属于状态清理，一个属于agg优化，优化配置要影响到原来的状态query状态清理么？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

?????? BLinkPlanner sql join????????

??Blinkplanner??oldplanner??1.10 package test.table.sql import java.util.Properties import com.souhu.msns.huyou.PublicParams import com.souhu.msns.huyou.utils.KafkaPbSchema import org.apache.flink.api.common.time.Time import

Re: BLinkPlanner sql join状态清理

Hi， 可以稳定复现吗？麻烦贴下flink版本和你的case, 我可以帮忙跟进确认下 Best， Leonard Xu > 在 2020年6月11日，14:30，op <520075...@qq.com> 写道： > > 大家好，最近发现一个问题 > 发现同一套代码，用oldPlanner设置IdleStateRetentionTime后join两边表的状态可以被定时清理，但是用blinkplanner同样的代码，运行却发现状态不会被清理，这是个bug吗？

BLinkPlanner sql join????????

??oldPlannerIdleStateRetentionTime??join??blinkplannerbug