storm-starter 是 apache storm 针对初学者的一个用maven管理的项目示例。这篇文章记录storm-starter例子代码分析及执行。
参考:https://github.com/apache/storm/tree/master/examples/storm-starter
1,$ mvn clean install -DskipTests=true
命令的执行结果如下:
它会在每个相应的目录下生成target文件夹。
看到如上编译提示的信息,storm-core 在storm/storm-core/target目录下
storm-hdfs、storm-hive等等,这些生成的jar包在 storm/external/target目录下
2,在本地模式下编译并运行ExclamationTopology
$ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology
3, package a jar suitable for submitting to a Storm cluster
$ mvn package
此时,在storm-start/target/目录下生成了一个storm-starter-0.11.0-SNAPSHOT.jar文件,里面的部分内容如下:
对应的java源文件如下:
4,对Topology提交
提交结果如下:
5,在storm UI 中查看提交Topology后的执行情况:
这里启动了一个supervisor
有一个提交了的Topology
Topology没有执行??