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)); *
--
考虑把 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