
218
10 章 Spark Streaming
このストリーミングの
UI
は、バッチの処理とレシーバの統計を表示してくれます。この例では
1
つのネットワークレシーバがあり、メッセージの処理のレートを見て取ることができます。処理
が追いついていない場合に、各レシーバが処理できるレコード数を見ることもできるでしょう。ま
た、レシーバに障害が起きているかもわかります。バッチ処理の統計は、バッチの処理にかかる時
間や、ジョブのスケジューリングに遅れが生じているかどうかも示します。クラスがに競合が起き
ているなら、スケジュールの遅延は大きくなっていくかもしれません。
10.8
フーンの
これまで
Spark
全般について議論してきたパフォーマンスに関する考慮点に加えて、
Spark
Streaming
アプリケーションには、特有のチューニングのポイントがあります。
10.8.1
バッンドのイ
最もよくある疑問は、
Spark Streaming
で使える最小のバッチサイズです。概して、多くのア
プリケーションの最小値としては、
500
ミリ秒が良い値だといわれています。最も優れたアプロー
チは、もっと大きなバッチサイズ(
10
秒程度)から始め、少しずつバッチサイズを小さくしてい
くことです。ストリーミングの
UI
で報告される処理時間が一定のままならバッチサイズを下げて
いってもかまいませんが、処理時間が増大しているようなら、そのアプリケーションでの限度に達
したと推測できます。
ウィンドウ処理の場合も同様に、結果を計算するインターバル(すなわちスライド期間)は、パ ...