未验证 提交 f26d2a7c 编写于 作者: D dailidong 提交者: GitHub

fix worker group config no effect (#2719)

上级 f4583d78
...@@ -130,7 +130,8 @@ masters="ds1,ds2" ...@@ -130,7 +130,8 @@ masters="ds1,ds2"
# run worker machine # run worker machine
# note: need to write the worker group name of each worker, the default value is "default" # note: need to write the worker group name of each worker, the default value is "default"
workersGroup=(["ds1"]="default" ["ds2"]="default" ["ds3"]="default" ["ds4"]="default" ["ds5"]="default")
declare -A workersGroup=(["ds1"]="default" ["ds2"]="default" ["ds3"]="default" ["ds4"]="default" ["ds5"]="default")
# run alert machine # run alert machine
# note: list of machine hostnames for deploying alert server # note: list of machine hostnames for deploying alert server
...@@ -141,4 +142,4 @@ alertServer="ds3" ...@@ -141,4 +142,4 @@ alertServer="ds3"
apiServers="ds1" apiServers="ds1"
# whether to start monitoring self-starting scripts # whether to start monitoring self-starting scripts
monitorServerState="false" monitorServerState="false"
\ No newline at end of file
...@@ -40,8 +40,8 @@ do ...@@ -40,8 +40,8 @@ do
for dsDir in bin conf lib script sql ui install.sh for dsDir in bin conf lib script sql ui install.sh
do do
# if worker in workersGroup # if worker in workersGroup
if [[ "${map[${host}]}" ]] && [[ "${dsDir}" -eq "conf" ]]; then if [[ "${workersGroup[${host}]}" ]] && [[ "${dsDir}" == "conf" ]]; then
sed -i ${txt} "s#worker.group.*#worker.group=${map[${host}]}#g" $workDir/../conf/worker.properties sed -i ${txt} "s#worker.group.*#worker.group=${workersGroup[${host}]}#g" ${dsDir}/worker.properties
fi fi
echo "start to scp $dsDir to $host/$installPath" echo "start to scp $dsDir to $host/$installPath"
...@@ -49,4 +49,4 @@ do ...@@ -49,4 +49,4 @@ do
done done
echo "scp dirs to $host/$installPath complete" echo "scp dirs to $host/$installPath complete"
done done
\ No newline at end of file
...@@ -43,5 +43,4 @@ for apiServer in ${apiServersHost[@]} ...@@ -43,5 +43,4 @@ for apiServer in ${apiServersHost[@]}
do do
echo "$apiServer worker server is starting" echo "$apiServer worker server is starting"
ssh -p $sshPort $apiServer "cd $installPath/; sh bin/dolphinscheduler-daemon.sh start api-server;" ssh -p $sshPort $apiServer "cd $installPath/; sh bin/dolphinscheduler-daemon.sh start api-server;"
done done
\ No newline at end of file
...@@ -43,5 +43,4 @@ for apiServer in ${apiServersHost[@]} ...@@ -43,5 +43,4 @@ for apiServer in ${apiServersHost[@]}
do do
echo "$apiServer worker server is stopping" echo "$apiServer worker server is stopping"
ssh -p $sshPort $apiServer "cd $installPath/; sh bin/dolphinscheduler-daemon.sh stop api-server;" ssh -p $sshPort $apiServer "cd $installPath/; sh bin/dolphinscheduler-daemon.sh stop api-server;"
done done
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册