Apache Flink 1.5-SNAPSHOT ドキュメント: Apache Flink ドキュメント 日本語訳
このドキュメントは Apache Flink バージョン 1.5-SNAPSHOT のものです。These pages were built at: 12/22/17, 09:50:21 AM UTC. Apache Flink は分散ストリームとバッチデータ処理のためのオープンソースプラットフォームです。Flinkの中核は、データ分散、通信、およびデータストリーム上の分散計算のための耐障害性を提供するストリーミング データフロー エンジンです。Flinkはストリーミングエンジン、ネイティブなイテレーションのサポート、管理されたメモリ、およびプログラムの最適化の上で、バッチ処理を構築することができます。 最初の一歩 概念: Flinkの データフロー プログラミング モデル と 分散ランタイム環境の基本的な概念から始めます。これはセットアップとプログラミングガイドを含めて、ドキュメントの他
Apache Flink 1.5-SNAPSHOT ドキュメント: 耐障害性 日本語訳
Flinkの耐障害性機構は障害時にプログラムを回復しそれらの実行を続けます。マシーンのハードウェア障害、ネットワーク障害、一時的なプログラムの障害などを含むそのような障害。 バッチ処理の耐障害性 (データセット API) 再試行の遅延 バッチ処理の耐障害性 (データセット API) データセット API内のプログラムのための耐障害性は、実行の失敗の再試行によって動作します。ジョブが失敗したと宣言される前にFlinkが実行を再試行する回数は、execution retries パラメータによって設定可能です。値0は事実上耐障害性が無効にされていることを意味します。 耐障害性を有効にするには、execution retries を0より大きな値に設定します。一般的な選択は3つの値です。 この例はFlinkデータセットプログラムのための実行の再試行を設定する方法を示します。 ExecutionE
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
