apache-storm - ストーム トライデントを使用する場合、並列処理を 2 以上に設定した場合、すべてのエグゼキューターを 1 つのサーバーだけでなく、異なるサーバーで実行するにはどうすればよいですか?

Question

つまり、並列度が 2 の場合、ボルトは 2 つの異なるサーバーで実行され、並列度が 3 の場合、ボルトは 3 つの異なるサーバーで実行されます。すべてのタスクを 1 つのサーバーだけで実行したくないので、これは私にとって重要です。それでは遅すぎます。

Answer 1

構成パラメーター「ワーカー数」(デフォルト値は 1) を増やしてみてください。

Config cfg = new Config();
cfg.setNumWorkers(...);

また、storm.yaml 構成パラメーターを使用して、ホストごとのワーカー数を制限することもできますsupersior.slots.ports。ポートごとに、1 つのワーカー JVM を開始できます。したがって、この構成に 1 つのポートのみを指定すると、1 つのワーカー JVM のみが開始されます。これにより、実行できるトポロジの数が制限される可能性があることに注意してください。単一のワーカー JVM は、(トポロジーを相互に分離するために) 単一のトポロジーからのコードのみを実行します。