7

マシンで Storm を構成しました。Zookeeper、Nimbus、Supervisor は正常に動作しています。ここで、この嵐にトポロジーを提出したいと思います。私は嵐の瓶を使用しようとしています。しかし、私はそれを提出することができません。誰でもこれの例を教えてください。とても役に立ちます。前もって感謝します：）

4

2 に答える 2

8

答えは公式ドキュメントにあり、十分に明確です。実行しますstorm jar path/to/allmycode.jar org.me.MyTopology arg1 arg2 arg3(プロジェクト名と引数があれば置き換えてください)。LocalCluster ではなく、StormSubmitter オブジェクトを使用していることを確認してください。

于 2013-09-19T09:39:57.963 に答える
5

残念ながら、インターネット上のほとんどすべての例は単語カウンターの例を示しており、簡単な方法で必要な手順については言及していません。

必要な作業は次のとおりです。 1.ストーム
ビン フォルダーに移動します。
cd /Users/nav/programming/apache-storm-1.0.1/bin
2. ニンバスを開始します
./storm nimbus
。 3. スーパーバイザーを開始します
./storm supervisor
。 4. ui プログラムを開始し
./storm ui
ます。 6.ファイルが有効であることを確認します(これはステップ 2 のはずです)。 7. コードで、8. を使用してトポロジーを送信していることを確認します。 もう一度 storm bin フォルダーに移動します 9. jar ファイルを storm に送信します 上記のコマンドは基本的に次のとおりです。
/Users/nav/programming/apache-storm-1.0.1/conf/storm.yaml
StormSubmitter.submitTopology

cd /Users/nav/programming/apache-storm-1.0.1/bin
./storm jar /Users/nav/myworkspace/StormTrial/build/libs/StormTrial.jar com.abc.stormtrial.StormTrial

stormExecutable jarOption pathToYourJarFile theClassContainingYourMainFile

コマンドライン引数をプログラムに渡したい場合は、最後に追加します。
stormExecutable jarOption pathToYourJarFile theClassContainingYourMainFile commandlineArguments

ここで、com.abc.stormtrialは完全なパッケージ名であり、関数.StormTrialを含むクラスの名前です。main

ブラウザを開いて入力するhttp://127.0.0.1:8080と、Storm の UI を介して実行されているトポロジが表示されます。

于 2016-05-27T07:03:05.747 に答える