storm-helloworld
软件架构说明
安装Java 7和Pythong 2.6.6
下载storm安装包,解压缩,重命名,配置环境变量 tar -zxvf apache-storm-1.1.0.tar.gz mv apache-storm-1.1.0 storm
vi ~/.bashrc export JAVA_HOME=/usr/java/latest export ZOOKEEPER_HOME=/usr/local/zookeeper export SCALA_HOME=/usr/local/scala export STORM_HOME=/usr/local/storm
export PATH=$PATH:$JAVA_HOME/bin:$ZOOKEEPER_HOME/bin:$SCALA_HOME/bin:$STORM_HOME/bin source ~/.bashrc
vi /usr/local/storm/conf/storm.yaml
storm.zookeeper.servers:
nimbus.seeds: ["192.168.1.100"]
storm.local.dir: "/var/storm"
#slots.ports,指定每个机器上可以启动多少个worker,一个端口号代表一个worker supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703
在另外两台机器安装:
scp /.bashrc root@hadoop04:/
scp -r storm root@hadoop04:/usr/local/
mkdir /var/storm
source ~/.bashrc
一个节点,storm nimbus >/dev/null 2>&1 & 三个节点,storm supervisor >/dev/null 2>&1 & 一个节点,storm ui >/dev/null 2>&1 & 我们需要在两个supervisor节点上,启动logview,然后才能看到日志:storm logviewer >/dev/null 2>&1 &
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。