azkaban.sh
#!/bin/bash
user=`whoami`
hadoop='hadoop'
case $1 in
"start")
for((host=102; host<=104; host++))
do
echo "====== start $user@$hadoop$host azkaban-exec-server ======"
ssh $user@$hadoop$host "cd /opt/module/azkaban/azkaban-exec-server/;bin/start-exec.sh"
sleep 10s
ssh $user@$hadoop$host "cd /opt/module/azkaban/azkaban-exec-server/;curl -G \"$hadoop$host:\$(<./executor.port)/executor?action=activate\" && echo"
done
echo "====== start $user@hadoop102 azkaban-web-server ======"
ssh hadoop102 "cd /opt/module/azkaban/azkaban-web-server/;bin/start-web.sh"
;;
"stop")
echo "====== stop $user@hadoop102 azkaban-web-server ======"
ssh hadoop102 "cd /opt/module/azkaban/azkaban-web-server/;bin/shutdown-web.sh"
for((host=102; host<=104; host++))
do
echo "====== stop $user@$hadoop$host azkaban-exec-server ======"
ssh $user@$hadoop$host "cd /opt/module/azkaban/azkaban-exec-server/;bin/shutdown-exec.sh"
done
;;
*)
echo "参数输入错误"
esac
网友评论