3

投機 = を使用して Spark でジョブを実行するとしtrueます。

タスク (T1 としましょう) に長い時間がかかる場合、Spark は T1 を強制終了することなく、別のエグゼキュータでタスク T1、たとえば T2 のコピーを起動します。

さて、T2 にも正常に完了したすべてのタスクの中央値よりも多くの時間がかかる場合、Spark は別のタスク T3 を別のエグゼキューターで起動しますか?

はいの場合、この新しいタスクの生成に制限はありますか? いいえの場合、Spark は 1 つの並列ジョブに制限され、いずれかの完了を無期限に待機しますか?

4

1 に答える 1