Storm單機安裝

2021-08-10 16:23:41 字數 1081 閱讀 1506

vim storm.yaml

##zookeeper


storm.zookeeper


.servers:


- "localhost"


##nimbus所在節點


nimbus.seeds: ["localhost"]


##可用埠號配置，每個對應乙個worker，可配置多個


supervisor.slots


.ports:


- 6700

##先啟動zookeeper


zkserver.sh start
主控節點執行nimbus守護程序，類似於hadoop中的jobtracker，負責在集群中分發**，對節點分配任務，並監視主機故障。所以再啟動nimbus。

##啟動nimbus


./bin/storm nimbus &
./bin/storm ui &
supervisor負責監聽工作節點上已經分配的主機作業，啟動和停止nimbus已經分配的工作程序。

##啟動supervisor


./bin/storm supervisor &
./bin/storm jar /users/delin/stromdemo/target/strom-demo-1.0-snapshot.jar


com.ailpha


.******topology wordcount
格式：storm kill name -w seconds

storm kill wordcount -w 10
格式：storm deactivte name

storm deactivte wordcount
格式：storm activate name

格式：storm rebalance name

storm rebalance wordcount

Storm 單機 集群安裝部署

官方文件 注意 storm.yaml 每個屬性名前和冒號後都要有個空格，不然會解析錯誤 zookeeper 集群位址 storm.zookeeper.servers 127.0.0.1 nimbus.seeds 127.0.0.1 storm.local.dir users qiaojialin d...

storm單機版部署

zeromq jzmq storm zookeeper 解壓zookeeper，然後修改conf檔案中的zoo.cfg ticktime 2000 datadir var zookeeper clientport 2181 由於是單機版的，就只新增了這幾個引數，其中目錄需要自己先建立 啟動zooke...

storm安裝 3 storm本身的安裝

這裡我用的版本是storm 0.8.2.zip 新增許可權 chmod x storm 0.8.2.zip 進行檔案的解壓 unzip storm 0.8.1.zip 如果沒有安裝unzip，可以使用 yum install unzip進行安裝 然後把解壓的檔案複製到 usr local 資料夾中 ...