storm啟動和拓撲啟動和關閉的一般命令


storm啟動步驟:

1- 啟動zookeeper(storm需要依賴zookeeper)

zkServer.sh start

2- 啟動nimbus(只需啟動一台主控節點的守護線程,負責在集群中分發代碼,對節點分配任務,並監視主機故障)

storm nimbus

3- 啟動supervisor(每個工作節點運行supervisor守護進程,負責監聽工作節點已經分配的主機作業,啟動和停止nimbus已經分配的工作進程)

storm supervisor

4- 啟動UI(監控頁面,只需啟動一台服務器,進程名為core)

storm ui

 

5- 刪除拓撲

storm kill topname

6- 激活拓撲

storm active topname

7- 不激活拓撲

storm deactive topname

8- 列出拓撲

storm list

 

啟動命令zookeeper(多台):

#!/bin/shell
echo "start zookeeper server..."
#hosts里是安裝zookeeper的主機名
hosts="master node1 node2 node3"
#用循環來分別執行zkServer.sh start的腳本
for host in $hosts
do
  echo "--------$host--------"
  ssh $host  "source /etc/profile; /home/hadoop/zookeeper-3.4.10/bin/zkServer.sh start"
done

啟動storm

#!/bin/bash
echo "start storm server..."
source /etc/profile
storm nimbus >${STORM_HOME}/nimbus.log 2>&1 &
storm ui >${STORM_HOME}/ui.log 2>&1 &
hosts="node1 node2 node3"
for host in $hosts
  do
    echo "--------$host--------"
    ssh $host  "source /etc/profile; ${STORM_HOME}/bin/storm supervisor >${STORM_HOME}/supervisor.log 2>&1 &"
    echo "OK!"
  done

關閉storm

#!/bin/bash
source /etc/profile
echo "stop storm server..."
kill -9 `ps -ef|grep daemon.nimbus | awk '{print $2}'|head -1` >${STORM_HOME}/nimbus.log 2>&1
kill -9 `ps -ef|grep core | awk '{print $2}'|head -1` >${STORM_HOME}/ui.log 2>&1
hosts="node1 node2 node3"
for host in $hosts
do
  echo "--------$host--------"
  ssh $host "source /etc/profile; /home/hadoop/shelltools/stop-supervisor.sh >${STORM_HOME}/supervisor.log 2>&1 &"
  echo "OK!"
done


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM