Storm Cluster安装
@[安装|storm]
1. 上传storm安装包到服务器
- 在120,121,122,123四台机器的
/apps/
目录下安装apache-storm-0.9.1-incubating
2. 安装Zookeeper
- 由于121,123,124上已有Zookeeper,所以不安装Zookeeper了
3. 安装Java和Python
- Java1.7
- Python2.6.6
4. 解压下载的storm release到Nimbus和worker机器
5. 修改conf/storm.yaml配置文件
- storm.zookeeper.servers: zookeeper cluster的主机列表
storm.zookeeper.servers: - "10.0.8.121" - "10.0.8.123" - "10.0.8.124" # 若修改了zookeeper的默认端口,需配置storm.zookeeper.port参数: storm.zookeeper.port: 2181
- storm.local.dir: 存储Nimbus和Supervisor守护进程的状态量
storm.local.dir: "/apps/apache-storm-0.9.1-incubating/data"
- nimbus.host: master机器的IP(以便worker nodes从master下载topology jars和confs)
nimbus.host: "10.0.8.120"
- supervisor.slots.ports: 每个worker机器运行4个进程,每个进程使用一个独立端口接收消息
supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703
6. 启动守护进程
- Nimbus: 在master机器上运行
bin/storm nimbus
- Supervisor: 在每个worker机器上运行
bin/storm supervisor
- StormUI: 运行
/bin/storm ui
启用stormUI
7. 搭建StormUI
- 在120上搭建StormUI,端口: 8080
- 通过http://10.0.8.120:8080访问StormUI
时间: 2024-10-10 17:42:15