Flink流：TriggerResult之间的不同。火灾和触发结果。FIRE\u和\u PURGE

Question

我是Flink的新手。我有一个Flink流媒体程序，在10秒的会话窗口中计算Kafka的内容。

以下是我的问题：

会话windows的默认触发器为FIRE。

Flink streaming是否会将每个窗口的所有Kafka消息保留在内存中？或者只保留聚合结果。

如果使用FIRE\u和\u PURGE，将清除什么？

Answer 1

这里描述了触发和清除，但简单地说，区别在于，FIRE\u和\u PURGE会在触发后删除窗口的内容。

Flink的所有内置窗口分配器（包括会话窗口）都会在时间合适的时候清除它们的内容，即在任何允许的延迟到期之后。但是清除是作为一个单独的步骤完成的，而不是与触发器触发相结合。

Windows的内容保持在Flink状态，因此其位置取决于您使用的后端状态。如果使用基于堆的状态后端，则此状态将保留在堆上；如果使用RocksDB，则此状态将保留在磁盘上。

在清除之前，您的窗口是否保留其全部内容取决于您是否使用增量聚合——换句话说，如果您使用的是reduce、aggregate或fold，则只存储聚合的持续结果，否则它是分配给窗口的所有事件的集合。