flinkSQL的ValueStateDescriptor没有设置StateTtlConfig

[stgztsw]

目前用的是flink1.10的版本，发现flinkSQL的场景(rocksdb)，除了streamingJoinOperator以外，ValueStateDescriptor都没有设置StateTtlConfig，这样的话会不会导致groupby之类的聚合操作的状态永远不会被清理，而导致越来越大？好像也没有任何配置来调整？这是不是不太合理？



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

[沉醉寒風]

streamTableEnv.getConfig().setIdleStateRetention(Duration.ofDays(1));




------------------ 原始邮件 ------------------
发件人: "stgztsw"<[hidden email]&gt;;
发送时间: 2021年2月4日(星期四) 下午3:33
收件人: "user-zh"<[hidden email]&gt;;
主题: flinkSQL的ValueStateDescriptor没有设置StateTtlConfig



目前用的是flink1.10的版本，发现flinkSQL的场景(rocksdb)，除了streamingJoinOperator以外，ValueStateDescriptor都没有设置StateTtlConfig，这样的话会不会导致groupby之类的聚合操作的状态永远不会被清理，而导致越来越大？好像也没有任何配置来调整？这是不是不太合理？



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