开发者社区> 问答> 正文

flink1.10.1/1.11.1 使用sql 进行group 和 时间窗口 操作后 状态越来越大

在测试环境: 

关闭增量chk,全量的state大小大约在:100M左右; 

之前开启:我观察了一段时间,膨胀到5G,而且还一直在增长; 

sql: 

select sum(xx) group by 1 分钟窗口 

过期时间设置的为:5-30min*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:47:51 690 0
1 条回答
写回答
取消 提交回答
  • 一般性的推断是,模式 是属于配置项,若出现问题了,系统读取 或者 改变 配置项,能解决问题么? 

    之前的学习经验,计算机的解决方案是 出现问题,大都是保护现场,等问题解决后,释放现场。 

    状态 可以 类比是现场,当问题出现的时候,重点在状态的保护是怎么实现的,和配置没有太大关系,因为完全可以不读取配置。 

    配置项是面向用户选择 state 的方式,不是解决问题的方式。*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:28:49
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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