大家好:
        版本: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为什么没变小?

回复