You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 沉醉寒風 <10...@qq.com> on 2021/02/04 07:36:23 UTC
回复：flinkSQL的ValueStateDescriptor没有设置StateTtlConfig
streamTableEnv.getConfig().setIdleStateRetention(Duration.ofDays(1));
------------------ 原始邮件 ------------------
发件人: "stgztsw"<stgztsw@126.com>;
发送时间: 2021年2月4日(星期四) 下午3:33
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: flinkSQL的ValueStateDescriptor没有设置StateTtlConfig
目前用的是flink1.10的版本，发现flinkSQL的场景(rocksdb)，除了streamingJoinOperator以外，ValueStateDescriptor都没有设置StateTtlConfig，这样的话会不会导致groupby之类的聚合操作的状态永远不会被清理，而导致越来越大？好像也没有任何配置来调整？这是不是不太合理？
--
Sent from: http://apache-flink.147419.n8.nabble.com/