我有一个管道,它使用Flink Global Window和基于事件时间的自定义触发器(从到达元素的时间戳开始)和Evictor,它从窗口中剪切不必要的元素并将其传递给ProcessFunction。.keyBy(Elements::getId) .triggerMyWindowProcessFunction,但我需要测试整个
也可以说,我必须使用全局窗口(需求)。) .window(GlobalWindows.create()) // assume this is a requirement
如果我将其中一个记录(例如,使用更新的字段)从一个流重新发送到该流,则会发出两个重复的联接事件。Flink社区的人能解释一下为什么会发生这种情况吗?我原以为每次只发出一个事件。是否有可能通过一个全局<
我有一个键控窗口流处理应用程序(KeyStream.window.process),窗口是一个15分钟的翻滚窗口。我想知道一个新的窗口处理什么时候开始,这个窗口处理什么时候结束,这样我就可以利用这个机会做一些清理/初始化工作globally。对于每个窗口,在处理开始之前,我想做一些初始化工作,比如截断一个db表(这个操作应该只在一个地方发生,这是一个全局操作,不应该在process方法中完成)。当processing窗口结束时( proces