我们使用带水印的周期事件时间窗口。我们目前在flink应用程序中有4个并行任务。
在流处理过程中,所有4个任务的水印值必须接近触发窗口事件。
例如;
任务1水印值=8
任务2水印值=1
任务3水印值=8
任务4水印值=8
任务2正在等待日志更新其水印。但是,这种情况可能发生在任务2更新之前,我们希望在更新之前触发窗口事件。
是否有任何机制来对齐所有并行任务的水印或在不等待其他任务的情况下触发窗口事件?
我们使用带水印的周期事件时间窗口。我们目前在flink应用程序中有4个并行任务。
在流处理过程中,所有4个任务的水印值必须接近触发窗口事件。
例如;
任务1水印值=8
任务2水印值=1
任务3水印值=8
任务4水印值=8
任务2正在等待日志更新其水印。但是,这种情况可能发生在任务2更新之前,我们希望在更新之前触发窗口事件。
是否有任何机制来对齐所有并行任务的水印或在不等待其他任务的情况下触发窗口事件?
暂无答案!
目前还没有任何答案,快来回答吧!