Re: flink 状态设置

2023-05-14 文章 Shammon FY
Hi, "如果不对于状态进行管理,后续程序会出现问题"是指状态会变得太大?如果是这样,可以在group by的字段里增加一个天级的时间戳,这样就不会由于key被更新导致的状态过期失效问题 Best, Shammon FY On Fri, May 12, 2023 at 1:59 PM 小昌同学 wrote: > 各位老师好,我这边使用的flink sql是" > select funcId,funcIdDesc,serverIp,cast(min(maxTime-minTime) as > varchar(200)) as minTime,pk from > ( >

flink 状态设置

2023-05-11 文章 小昌同学
各位老师好,我这边使用的flink sql是" select funcId,funcIdDesc,serverIp,cast(min(maxTime-minTime) as varchar(200)) as minTime,pk from ( select a.funcId as funcId , a.funcIdDesc as funcIdDesc, a.serverIp as serverIp, b.outTime as maxTime, a.outTime as minTime, concat(a.funcId,a.serverIp) as pk