storm集群安装

机器:(storm及zookeeper都是这3台机器)

192.168.80.20

192.168.80.21

192.168.80.22

须要准备的软件有:

zookeeper(zookeeper-3.4.4.tar.gz),storm(storm-0.8.1.zip) ,jdk

1、配置zookeeper

这里就不介绍了!

2、配置storm

解压storm

进入conf文件夹,编辑storm.yaml文件

########## These MUST be filled in for a storm configuration

 storm.zookeeper.servers:

     - "192.168.80.20"

     - "192.168.80.21"

- "192.168.80.22"

nimbus.host: "192.168.80.20"





 storm.local.dir: "/opt/storm/data"

 ##### These may optionally be filled in:





# List of custom serializations

# topology.kryo.register:

#     - org.mycompany.MyType

#     - org.mycompany.MyType2: org.mycompany.MyType2Serializer

#

## List of custom kryo decorators

# topology.kryo.decorators:

#     - org.mycompany.MyDecorator





# Locations of the drpc servers

# drpc.servers:

    # - "127.0.0.1"

     #- "server2"

## to nimbus 

#nimbus.childopts: "-Xmx1024m" 

#

## to supervisor 

#supervisor.childopts: "-Xmx1024m" 

#

## to worker 

#worker.childopts: "-Xmx768m"

3、配置完毕之后。開始启动zookeeper和storm

启动zookeeper

bin/zkServer.sh start

启动storm

bin/storm nimbus(在192.168.80.20启动主节点) 或者 nohup bin/storm nimbus > /dev/null 2>&1 &

bin/storm supervisor (在192.168.80.21启动从节点)或者  nohup
bin/storm
supervisor > /dev/null 2>&1 &

bin/storm
supervisor (在192.168.80.22启动从节点)或者 nohup
bin/storm supervisor >
/dev/null 2>&1 &

bin/storm ui (在192.168.80.20启动界面) 或者 nohup
bin/storm ui >
/dev/null 2>&1 &

浏览器打开: http://192.168.80.20:8080 查看集群的执行状态

搞定了!

。!!!

。!

最新文章

  1. Java hashCode() 和 equals()的若干问题
  2. Android使用SAX解析XML(3)
  3. Mysql 创建用户 授权
  4. sun.misc.BASE64Encoder和sun.misc.BASE64Encoder 找不到解决的方法
  5. disable_functions(禁用php函数)
  6. ionic list item-radio checked
  7. altium designer不经过原理图直接在空白pcb上加封装然后画线
  8. CoreCLR文档翻译 - GC的设计
  9. 深入研究 Mini ASP.NET Core(迷你 ASP.NET Core),看看 ASP.NET Core 内部到底是如何运行的
  10. P4180 严格次小生成树[BJWC2010] Kruskal,倍增
  11. strncpy的用法
  12. Nginx配置以及域名转发
  13. 关于pythoh面向过程开发人员三步转面向对象的补充,再加一步,四步走战略。转面向对象也可以有固定公式。
  14. 小程序 去掉 <button /> 组件默认 border 边框样式
  15. EventBus结合rxjava2和retrofit2网络获取
  16. fdisk vs df
  17. HashSet源码解析
  18. input 模糊搜索
  19. 粘包、拆包发生原因滑动窗口、MSS/MTU限制、Nagle算法
  20. IIS服务器支持.apk文件下载

热门文章

  1. android判断服务是否是运行状态
  2. excel 截取单元格部分内容(从指定位置截取)
  3. 学习C#——性能计数器
  4. 文件流(fstream, ifstream, ofstream)的打开关闭、流状态
  5. hdu 4779 Tower Defense (思维+组合数学)
  6. Mycat和MySQL的差别——Mycat的核心作用
  7. ItelliJ项目打jar包
  8. 关闭危害的端口DOS命令(转载)
  9. IIS目录禁止执行权限
  10. Cookie/Session编码