6

他のストーム ユーザー:

ストーム クラスターをセットアップするためのガイドライン ( https://github.com/nathanmarz/storm/wiki/Setting-up-a-Storm-cluster ) は、すべてのワーカーに対して別のポートを割り当てるマシン上。

私の理解では、各ワーカーはニンバスコントローラーからのコマンドをリッスンする JVM インスタンスです。したがって、それぞれが個別のポートでリッスンすることは理にかなっています。

ただし、 backtype.storm.Config には、ワーカーの数を定義できるように見えるメソッドもあります。setNumWorkers の呼び出しで、ポートを構成したよりも多くのワーカーを設定しようとした場合はどうなりますか? それは物事を台無しにするようです。

私にとって理にかなっている唯一のことは、yaml 構成がワーカー数の上限を定義していることです。各トポロジーは、いくつかのワーカーがそれに割り当てられることを要求する場合があります。しかし、それぞれ Config.setNumWorkers(2) を呼び出す 2 つのトポロジを (ある特定のクラスターに) 送信した場合は、4 つのポートを構成したほうがよいでしょう。

これは正しい考えですか？

前もって感謝します..-クリス

4

3 に答える 3

4

まあ、上限の推測は正しかったと思います。ラップトップに 1 台のマシンのストーム クラスターをセットアップし、(storm-starter から) ExclamationTopology を構築しました。2 つのワーカーのみをセットアップしましたが、ExclamationTopology には > conf.setNumWorkers(3); の呼び出しがあります。

しかし、ストーム UI を見ると、「Num Workers」が 2 であることがわかります。

したがって、storm.yaml ファイルで設定した内容は上限のようです。ポートを構成したよりも多くのワーカーを要求すると、利用可能な最大値が得られます。

(警告: 私はこの問題に取り掛かったばかりであり、決して専門家ではないので、何かを見逃している可能性があります..しかし、上記のレポートは私が観察したものです.)

于 2013-10-27T02:55:34.177 に答える