参阅:
http://www.cnblogs.com/freeweb/p/5179410.html 非常感谢
注意集群的启动顺序以及概念。
[root@master bin]# ./storm ui >> /dev/null &
[4] 8076
[root@master bin]# jps
7930 nimbus
8076 core
3667 SecondaryNameNode
3480 NameNode
7626 QuorumPeerMain
8207 Jps
3821 ResourceManager
整体比较顺利,出现了下面一个小问题:
at clojure.lang.RT.load(RT.java:436)at clojure.lang.RT.load(RT.java:412)at clojure.core$load$fn__5448.invoke(core.clj:5866)at clojure.core$load.doInvoke(core.clj:5865)at clojure.lang.RestFn.invoke(RestFn.java:408)at clojure.lang.Var.invoke(Var.java:379)at org.apache.storm.daemon.nimbus.<clinit>(Unknown Source)
Caused by: while scanning a simple keyin 'reader', line 27, column 1: at clojure.lang.RT.load(RT.java:436)
at clojure.lang.RT.load(RT.java:412)
at clojure.core$load$fn__5448.invoke(core.clj:5866)
at clojure.core$load.doInvoke(core.clj:5865)
at clojure.lang.RestFn.invoke(RestFn.java:408)
at clojure.lang.Var.invoke(Var.java:379)
at org.apache.storm.daemon.nimbus.<clinit>(Unknown Source)
Caused by: while scanning a simple keyin 'reader', line 27, column 1:storm.local.dir:"/data/storm"^
could not found expected ':'in 'reader', line 29, column 1:supervisor.slots.ports:^ at org.apache.storm.shade.org.yaml.snakeyaml.scanner.ScannerImpl.stalePossibleSimpleKeys(ScannerImpl.java:460)
at org.apache.storm.shade.org.yaml.snakeyaml.scanner.ScannerImpl.needMoreTokens(ScannerImpl.java:280)^
could not found expected ':'in 'reader', line 29, column 1:supervisor.slots.ports:^at org.apache.storm.shade.org.yaml.snakeyaml.scanner.ScannerImpl.stalePossibleSimpleKeys(ScannerImpl.java:460)at org.apache.storm.shade.org.yaml.snakeyaml.scanner.ScannerImpl.needMoreTokens(ScannerImpl.java:280)
明显就是格式问题。按照如下修改即可,storm.yaml 注意空格区分
storm.local.dir: "/data/storm"
storm启动的时候 所有进程需要后台一直执行,可参考如下命令:
/opt/storm/bin/storm nimbus &
/opt/storm/bin/storm supervisor &
/opt/storm/bin/storm ui &