2017-10-22 7 views
0

Flinkドキュメントには、データストリームapiの配信保証が1回または少なくとも1回しか記載されていませんが、データセットapiの参照は見つかりませんでした。Flink dataset api配送保証とチェックポイント

メッセージは、データセット内のすべてのトランスフォーメーションに正確に1回配信されることが保証されていますか。さらに、チェックポイントメカニズムがない場合、最初からジョブを開始することだけが論理的頼りになります。

データストリームapiをバッチジョブに使用できますか?

答えて

0

DataSet APIのフォールトトレランスはhereと記載されていますが、失敗したジョブの再試行に基づいています。

あなたは確かに有限(バッチ)ジョブのためにDataStream APIを使用することができます。バッチAPIにはマシンラーニングやグラフライブラリなどのいくつかの機能があり、DataSet APIにはDataStreamでは使用できない最適化機能がいくつかありますが、多くのアプリケーションでその違いは重要ではありません。

関連する問題