storm on yarn(CDH5) 部署笔记

按照storm on yarn(Apache hadoop)部署好以后,而后修改HADOOP_HOME,hadoopenv.sh中的JAVA_HOME,以及storm-yarn-master中pom.xml的hadoop versionjava

启动顺序依次为:apache

hdfs:start-dfs.shapp

yarn:start-yarn.shoop

zookeeper:zkServer.sh startui

stormspa

nimbus:storm nimbus.net

UI:storm ui   #localhost:8080regexp

supervisor:storm supervisor    若是有从节点的话orm

提交storm任务:xml

  storm-yarn launch storm.yaml

存储storm.yaml文件到.storm,这样使用storm命令提交jobs时,会找到该文件  ---个人这一步出错,可是在apache hadoop下成功了

  storm-yarn getStormConfig -appId application_1381089732797_0025 -output ~/.storm/storm.yaml

提交Topology

  storm jar lib/storm-starter-0.0.1-SNAPSHOT.jar storm.starter.WordCountTopology WordCountTopology -c nimbus.host=<your nimbus host>

监控Topology

  查看Storm ui,地址是:http://<your nimbus host>:8080

关闭Topology

  storm kill [Topology_name] 

关闭Storm on yarn集群

  storm-yarn shutdown –appId [applicationId]

致谢:http://blog.csdn.net/m_vptr/article/details/9962613

 

错误:15/07/19 00:31:46 INFO yarn.StormOnYarn: application report for application_1437236195968_0001 :N/A:-115/07/19 00:31:46 INFO yarn.StormOnYarn: Attaching to N/A:-1 to talk to app master application_1437236195968_0001Exception in thread "main" java.lang.IllegalArgumentException: invalid port: -1待解决

相关文章
相关标签/搜索