Apache Flink 1.10 Documentation: Data Streaming Fault Tolerance

This document describes Flink’s fault tolerance mechanism for streaming data flows. Introduction Checkpointing Barriers State Exactly Once vs. At Least Once Asynchronous State Snapshots Recovery Operator Snapshot Implementation Introduction Apache Flink offers a fault tolerance mechanism to consistently recover the state of data streaming applications. The mechanism ensures that even in the presen

[kimutansk]

FlinkのSnapshot取得タイミングはメッセージに仕込む方式。GearpumpですとAkkaの性質を使った定期実行方式。微妙に違いますが大勢には影響は出ない。