像 groupby 或 combine 这样的东西需要 exactly once 保证像 sum 这样的微不足道的计算
但是 apache beam 似乎没有在库中内置检查点，它是否依赖于 flink 或 spark 来管理容错和状态一致性？