你好: 使用的state backend是rocksdb,没有开启增量,后续没有再插入过数据。
> 在 2021年1月14日,下午4:07,Yun Tang <myas...@live.com> 写道: > > 使用的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为什么没变小?