开发者社区> 问答> 正文

flink sql子查询状态清理不掉

大家好,我现在程序里面有像这样一段sql:  select day,

           count(id),

           sum(v1) from

(

select 

          day ,

          id ,

          sum(v1) v1 from source

      group by day,

                   id

)t

group by day

我设置了

tConfig.setIdleStateRetentionTime(Time.minutes(1440),Time.minutes(1450))

子查询里面的聚合是按照天和id聚合的,按道理1天之后就会自动清理,但是运行4天过程中,我在checkpoint的页面里面看到这个子查询的状态一直在增大,这是什么原因呢

我的版本是1.10.0

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 15:20:50 1198 0
1 条回答
写回答
取消 提交回答
  • 感觉不太应该。你用的是哪个Flink版本,以及哪个planner呢?

    *来自志愿者整理的flink邮件归档

    2021-12-06 17:02:38
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载