Flink：使用允许的延迟时清除windows元数据

Question

如何在允许的延迟期结束之前“清除”窗口元数据（WindowOperator和InternalTimer）？

是否可以将此元数据与窗口数据本身一起清除？

我们不介意丢失元数据——不需要根据之前非延迟数据的上下文来处理具有相同关键时间的延迟事件。

一些背景知识-

[目前正在使用Flink-v1.6]我们正在处理事件时间窗口，并处理大量具有唯一键的事件。95%的活动不会迟到，只会开火一次。

我们的工作规定允许迟到72小时。我们用火

Answer 1

通常，如果您需要自定义状态管理，我建议使用ProcessFunction而不是Flink的窗口API，因为它比将相关逻辑分布在窗口分配器、触发器、驱逐器和进程窗口函数中更容易理解和维护。

在你的例子中，一个想法确实出现在脑海中：如果你没有长时间的允许迟到，而是将迟到的事件收集到一个辅助输出中，这对你有用吗？

更新时间：

保留的元数据是能够继续向窗口添加事件所需的状态。这是允许迟到的代价。