首页 > 其他 > 详细

storm0.9-single

时间:2014-06-08 21:44:06      阅读:455      评论:0      收藏:0      [点我收藏+]

参考

http://shiyanjun.cn/archives/241.html

用新版包自己做了一遍

(1)安装zeromq4&jzmq

[安装依赖]
yum install uuid*
yum install libtool
yum install libuuid
yum install libuuid-devel

[安装zeromq]
cd zeromq-4.0.4
./configure (不要使用--prefix指定路径,我试着在这里指定了一下结果后面jzmq就找不到zmq.h)
make
make install

[安装jzmq]
git clone git://github.com/nathanmarz/jzmq.git
cd jzmq/
./autogen.sh
./configure
make
make install

 

(2)安装zookeeper

vi ~/.bashrc

#ZooKeeper
export ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.6
export PATH=$PATH:$ZOOKEEPER_HOME/bin

source ~/.bashrc

 

(3)安装storm

[环境变量]

vi ~/.bashrc

#Storm
export STORM_HOME=/home/hadoop/soft/apache-storm-0.9.1-incubating
export PATH=$PATH:$STORM_HOME/bin

source ~/.bashrc

[配置]

vi ./conf/storm.yaml (注意yaml格式的要求,空格tab,:和-前后都有空格)

storm.zookeeper.servers:
        - "localhost"

storm.zookeeper.port : 2181
nimbus.host : "localhost"
storm.local.dir : "/home/hadoop/soft/apache-storm-0.9.1-incubating/tmp"
supervisor.slots.ports:
  - 6700

  - 6701

  - 6702

 

(4)运行示例

[下载示例源码编译打包]

git clone https://github.com/nathanmarz/storm-starter.git
cd storm-starter/
mvn -f m2-pom.xml package

[启动服务]

启动zookeeper

./zkServer.sh start

启动storm

storm help 可以看到有很多的命令
Commands:
    activate
    classpath
    deactivate
    dev-zookeeper
    drpc
    help
    jar
    kill
    list
    localconfvalue
    logviewer
    nimbus
    rebalance
    remoteconfvalue
    repl
    shell
    supervisor
    ui
    version

Help:
    help
    help <command>

storm nimbus (启动积雨云)

storm supervisor  (启动工作节点)

storm ui  (启动web界面)

[hadoop@localhost logs]$ netstat -an|grep 6700
[hadoop@localhost logs]$ netstat -an|grep 6701
[hadoop@localhost logs]$ netstat -an|grep 6702

此时三个工作端口均未启动

web界面查看

http://localhost:8080/

[不带Topology名提交Topology]

storm jar ../storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology

这中情况不会提交到nimbus去运行

[提交Topology]

storm jar ../storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology myFirstStormApp

 [查看Topology]

storm list

Topology_name        Status     Num_tasks  Num_workers  Uptime_secs
-------------------------------------------------------------------
myFirstStormApp      ACTIVE     28         3            26063

[提交同名的Topology]

Exception in thread "main" java.lang.RuntimeException: Topology with name `myFirstStormApp` already exists on cluster
    at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:89)
    at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:58)
    at storm.starter.WordCountTopology.main(WordCountTopology.java:77)

[杀死Topology]

Topology_name        Status     Num_tasks  Num_workers  Uptime_secs
-------------------------------------------------------------------
myFirstStormApp      KILLED     0          0            26126

过一段时间后

No topologies running.

(5)日志查看

tail -100f logs/nimbus.log

tail -100f logs/supervisor.log

tail -100f logs/worker-6700.log

tail -100f logs/worker-6701.log

tail -100f logs/worker-6702.log

 

storm0.9-single,布布扣,bubuko.com

storm0.9-single

原文:http://www.cnblogs.com/really-dt/p/3775663.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!