Hi zhanglachun, 你们使用 checkpoint 的方式是什么？是否有 full gc 的情况呢
Best, LakeShen 徐骁 <[email protected]> 于2020年8月26日周三 上午2:10写道： > input > .keyBy(<key selector>) > .timeWindow(<duration>) > .reduce(new MyReduceFunction(), new MyProcessWindowFunction()); > > 可以看一下官网的 reduce 用法, 可以在数据进入窗口的时候进行处理(排序), 而没必要等到 window 结束后再进行 这样可以把时间分散到 > window 里面 >
