ストリーミングエグゼキュータを異なるタイミングで起動する理由を教えてください。次のように

Question

私はソースとして使用していますカフカ1.6ストリーミングスパークを使用してい

私の入力引数です：

num-executors 5 
num-cores  4 
batch Interval 10 sec 
maxRate   600 
blockInterval 350 ms 

はなぜエグゼキュータの一部は、後に別のものより開始しません？

Answer 1

ない執行だ

開始時間が、タスクの開始時刻。

これはローカリティスケジューリングの可能性が高いためです。スパークは、タスクの開始を遅らせ、そのタスクを実行するための最善のエグゼキュータを見つけました。詳細はSpark's documentationの "spark.locality.wait"の設定を確認してください。