Storm 本机运行 提交StormSubmitter

1. Storm 启动

#启动Zookeeper
nohup sh storm dev-zookeeper &
#启动主节点
nohup sh storm nimbus &
#启动从节点
nohup sh storm supervisor &
#启动UI界面
nohup sh storm ui &
#启动日志查看服务
nohup sh storm logviewer &

2.程序修改

public static void main(String[] args){
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("DataSourceSpout", new DataSourceSpout());
        builder.setBolt("SumBolt", new SumBolt()).shuffleGrouping("DataSourceSpout");

        String topoName = ClusterSumStormAckerTopology.class.getSimpleName();

        try {
            StormSubmitter.submitTopology(topoName,new Config(),
                    builder.createTopology());
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

3. 提交jar运行

#格式
storm jar topology-jar-path class args0 args1 args2
#具体
storm jar ./target/bigdata-1.0.jar com.waiting.ClusterSumStormAckerTopology

4420

原文 

http://www.waitingfy.com/archives/4420

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Storm 本机运行 提交StormSubmitter

分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址