Re: Flink sql 状态过期后，checkpoint 大小没变化

Thu, 14 Jan 2021 00:07:21 -0800 

使用的state backend，以及对应的checkpoint 类型是什么（是否开启incremental checkpoint）？

在一开始插入数据后，直到state TTL超过，期间均没有再插入数据过么？还是说一直在以一定的数据量在插入数据？


祝好
唐云
________________________________
From: 孙啸龙 <sun_fl...@126.com>
Sent: Thursday, January 14, 2021 15:52
To: user-zh@flink.apache.org <user-zh@flink.apache.org>
Subject: Flink sql 状态过期后，checkpoint 大小没变化

大家好：
        版本：1.12.0
        方式：flink sql
        测试sql：
        select a.id,b.money,b.createTime from test_state_from a
        full join test_state_from1 b on a.id=b.id;
        问题：
       test_state_from和test_state_from1 分别插入50万条数据，查看 checkpoint 大小为83m，state 
ttl 设      置为16分钟，30分钟后查看checkpoint的值还是83m，状态过期清理后的checkpoint为什么没变小？

回复