1、运行jstorm项目
如下我的jstorm项目打包为: jstorm-test-1.0-SNAPSHOT.jar
jstorm jar jstorm-test-1.0-SNAPSHOT.jar wqp.topology.MyTopology "118.144.xxx.148"
即可
其中
jstorm jar xxxxxx.jar com.alibaba.xxxx.xx parameter
xxxx.jar 为打包后的jar
com.alibaba.xxxx.xx 为入口类,即提交任务的类
parameter即为提交参数
2、如何关闭到jstorm中的topology
jstorm kill MyTopology
其中MyTopology是对应的topology的名字
网友评论