flinksql ttl不生效

[chenchencc]

版本:1.12.2
sql:
SELECT id, name, message,ts       
SELECT
ROW_NUMBER() OVER (PARTITION BY name 
    ORDER BY ts DESC) AS rowNum
FROM persons_message_table_kafka
WHERE rowNum = 1
过期时间设置:tableEnv.getConfig().setIdleStateRetention(Duration.ofhour(3));

问题：checkpoint数据一直在线上增加，一开始90m，然后每天增长20m，但是源数据并没有太多增长



--
Sent from: http://apache-flink.147419.n8.nabble.com/