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

2020-12-17 文章 Storm☀️
flink 1.10.1 同样遇到这个问题 设置了ttl但是没有生效,请问题主解决该问题了吗? *sql*: select * from xx group by TUMBLE(monitor_processtime, INTERVAL '60' SECOND),topic_identity *60s的窗口,设置的过期时间是2分钟,但是checkpoint中状态还是在变大* *tEnv.getConfig().setIdleStateRetentionTime(Time.minutes(2), Time.minutes(5)); * --

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

2020-05-17 文章 tison
考虑把 SQL 贴成 gist 链接? Best, tison. claylin <1012539...@qq.com> 于2020年5月17日周日 下午5:32写道: > sql作业定义如下,也通过TableConfig设置了最大和最小idle > time,但是运行很长时间,查看sst的目录flink-io-8a4ac39d-b8c3-4baa-bd08-a063e6e964e9下,状态还是在一直变打,导致作业线程读写state很耗时间,最后作业处于一直反压状态,求大佬支招CREATE > TABLE yy_yapmnetwork_original ( happenAt