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 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