hi, all ! flink??????1.9?????????????????????????????????????????????????????????????????????????????????????????????????????????????? ??????select userId,sum(money) as result,ymd from ( select userId,order_id,money,DATE_FORMAT(trans_time,'yyyyMMdd') as ymd,row_number() over(partition by order_id order by last_modify_time desc) as rk from MyTable where type='1' ) t where t.rk = 1 group by userId,ymd; ??????tableConfig.setIdleStateRetentionTime(Time.milliseconds(3600000), Time.milliseconds(390000)); --????????????1?????????????? ??????checkpoint????????????????????????????ttl???????????????? ????????????jira??????????????????????????????1??????????????????????????????????????????
??1??https://issues.apache.org/jira/browse/FLINK-17096
