设置方法是: stenv.getConfig().setIdleStateRetentionTime(Time.hours(24), Time.hours(36)) 注意setIdleStateRetentionTime
项目代码设置: tEnv.getConfig().setIdleStateRetentionTime(org.apache.flink.api.common.time.Time.minutes(1),org.apache.flink.api.common.time.Time.minutes
StreamTableEnvironment tEnv = StreamTableEnvironment.create(sEnv, environmentSettings); tEnv.getConfig().setIdleStateRetentionTime
DELAY ‘1’ MINUTE BEFORE WATERMARK, WITHOUT DELAY AFTER WATERMARK --窗口结束之后,每条到达的数据都输出 tEnv.getConfig.setIdleStateRetentionTime
StreamTableEnvironment.getConfig().setIdleStateRetentionTime(min, max); 或者 StreamQueryConfig qConfig
领取专属 10元无门槛券
手把手带您无忧上云