向Storm提交拓扑

Question

我在我的机器上配置了Storm.Zookeeper,Nimbus和Supervisor正常运行.现在我想为这场风暴提交一个拓扑.我正在尝试使用风暴罐.但我无法提交.有人可以举个例子.这将非常有帮助.提前致谢:)

Answer 1

答案在官方文档中,很明显.运行storm jar path/to/allmycode.jar org.me.MyTopology arg1 arg2 arg3(替换为您的项目名称和参数,如果有的话).确保使用的是StormSubmitter对象而不是LocalCluster.

Answer 2

不幸的是，Internet上几乎所有示例都显示了计数器示例，并且没有以简单的方式提及所需的步骤：

您需要做的是：
1.导航到您的Storm bin文件夹：
cd /Users/nav/programming/apache-storm-1.0.1/bin
2.启动nimbus
./storm nimbus
3.启动Supervisor
./storm supervisor
4.启动ui程序
./storm ui
5.确保在构建jar文件时没有使用Storm jar。
6.确保您的/Users/nav/programming/apache-storm-1.0.1/conf/storm.yaml 文件有效（这应该是第2步）。
7.确保在您的代码中使用StormSubmitter.submitTopology
8. 提交拓扑。再次导航到storm bin文件夹
cd /Users/nav/programming/apache-storm-1.0.1/bin
。9.将jar文件提交到storm ./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运行。