Skip to content
This repository has been archived by the owner on Jun 16, 2023. It is now read-only.

JStorm on Apsara 使用向导

Longda edited this page Apr 15, 2014 · 3 revisions

流程设计

  1. 配置jstorm 的配置文件和fuxi的json配置文件, 将jstorm, nimbus_container, supervisor_container打包
  2. 使用rpc ap 命令将整个JStorm-on-Apsara的包(包括JStorm的包)一起上传上去
  3. 使用rpc sstart 命令启动整个jstorm集群
  4. 使用jstorm命令提交jar/杀死jar

客户端提供命令:

提供命令控制台,该控制台类似Zookeeper的zkCli.sh, 该控制台提供所有的子命令

  1. download-conf 下载 storm.yaml文件
  2. download-zip 下载 伏羲 的压缩包
  3. set-supervisor-num 设置supervisor的数量, 并启动新的supervisor
  4.  set-nimbus-num      设置nimbus的数量, 并启动新的nimbus    
    
  5. shutdown shutdown 整个jstorm cluster
  6. state 显示所有nimbus、supervisor运行状态, 其实就是封装rpc sstat
  7.  restart-nimbus      重启某个nimbus
    
  8.  restart-supervisor  重启某个supervisor
    

download-conf

参数

[-o –output]     获得的config 文件, 当没有设置output时,路径为~/.jstorm

返回

成功 0
失败 1, 并打印失败信息

download-zip

参数

[-o --output]   获得jstorm zip文件, 当没有设置output时,默认为本地路径

返回

0 成功
1 失败

set-supervisor-num

参数

数字          supervisor的数量

返回

0,	表示已经成功运行了n个supervisor
1,	表示失败

set-nimbus-num

参数

数字

返回

0,  成功, 
1,  失败

shutdown

###参数 无 ###返回

0 杀死所有nimbus和supervisor
1 失败

stat

参数

###返回

0, 打印每个supervisor和nimbus运行所在的节点
2,	返回失败

restart-nimbus

参数

hostname

返回

0, 成功, 并打印输出重启了nimbus
1, 失败

restart-supervisor

参数

hostname

返回

0, 成功, 并打印输出重启了supervisor
1, 失败
Clone this wiki locally