007-storm开发计数程序集群模式运行

1、主函数集群模式代码

String name = CountStormClusterTopology.class .getSimpleName()+System.currentTimeMillis ();
 /**
  *  Submits a topology to run on the cluster. 
  */
StormSubmitter. submitTopology(name, new Config(),topologyBuilder.createTopology());

2、 集群模式提交
storm jar storm.jar storm.CountStormClusterTopology

3、停止作业
先查询作业列表storm list

命令行下执行storm kill TopologyName

在storm ui上点击kill按钮