Hi,
我设置了状态过期,如下。使用内置函数LAST_VALUE后,观察lastCheckpointSize大小,发现其越来越大。
。请问,下面的设置对LAST_VALUE会生效吗?我应该怎么处理呢?感谢!
TableConfigtConfig=tableEnv.getConfig();
tConfig.setIdleStateRetentionTime(Time.hours(12),Time.hours(24));
- Re: 使用flinksql提供的内置函数LAST_VALUE 发现存的state越来越大 guoliang_wang1335
- Re: 使用flinksql提供的内置函数LAST_VALUE 发现存的state越来越大 guoliang_wang1335
- 使用flinksql提供的内置函数LAST_VALUE 发现存的state越来越大 guoliang_wang1335
