Flinkはイベント時間処理と遅延データの扱い、セーブポイントや増分チェックポイントによる状態管理を備え、公式アーキテクチャ説明では障害時もexactly-onceの状態一貫性を保証するとされています。SQLやDataStream APIで処理を記述でき、KubernetesやYARN上で動かせます。具体的な性能は構成やワークロードに依存するため、公式ページからは数値的な保証は読み取れません。
リアルタイム処理の信頼性に関する課題へのFlinkの機能
状態管理・イベント時間・耐障害性が一体で提供される点が特徴です。