apache-flink - Flink 窗口聚合(和其他操作)的结果是否保留在快照中?
问题描述
例如,如果我窗口化了一些数据和 .aggregate,如果系统出现故障,我创建的聚合器是否会重置?
解决方案
使用 Flink,窗口和聚合器中的状态包含在检查点中,并在发生故障/重启时恢复。Flink 的所有有状态操作也是如此。
推荐阅读
- java - java无法从文件中读取一行
- python - Python while 循环与 !=0
- apache-kafka - 如何从kafka的主题中创建具有大量JSON字段的KSQL Stream?
- javascript - ...state 究竟做了什么?
- python - 对 2D numpy 数组进行切片、索引和迭代
- aws-fargate - aws fargate 和网络成本
- python - Matlab 相当于 Python Panda 的 dtypes
- php - 这是 PHP 中的一个不好的做法吗?
- r - 为实验的模拟试验创建 R 循环
- java - PDFBox - 在动态填充的 PDF 表单的“另存为”功能上丢失复选框选择