Flink 窗口聚合(和其他操作)的结果是否持久化在快照中

Question

例如，如果我窗口一些数据和 .aggregate，如果系统出现故障，我创建的聚合器是否会重置？

Answer 1

使用 Flink，窗口和聚合器中的状态包含在检查点中，并在失败/重新启动时恢复。Flink 的所有有状态操作也是如此。