HADOOP-11668. hadoop-daemons.sh bw compat broke with --slaves change (Vinayakumar B via aw)
This commit is contained in:
parent
47f7f18d4c
commit
7711049837
|
@ -423,6 +423,9 @@ Trunk (Unreleased)
|
||||||
HADOOP-11653. shellprofiles should require .sh extension
|
HADOOP-11653. shellprofiles should require .sh extension
|
||||||
(Brahma Reddy Battula via aw)
|
(Brahma Reddy Battula via aw)
|
||||||
|
|
||||||
|
HADOOP-11668. hadoop-daemons.sh bw compat broke with --slaves change
|
||||||
|
(Vinayakumar B via aw)
|
||||||
|
|
||||||
OPTIMIZATIONS
|
OPTIMIZATIONS
|
||||||
|
|
||||||
HADOOP-7761. Improve the performance of raw comparisons. (todd)
|
HADOOP-7761. Improve the performance of raw comparisons. (todd)
|
||||||
|
|
|
@ -65,8 +65,13 @@ hadoop_error "WARNING: Attempting to execute replacement \"hdfs --slaves --daemo
|
||||||
# we're going to turn this into
|
# we're going to turn this into
|
||||||
# hdfs --slaves --daemon (start|stop) (rest of options)
|
# hdfs --slaves --daemon (start|stop) (rest of options)
|
||||||
#
|
#
|
||||||
argv=(${HADOOP_USER_PARAMS[@]/start})
|
for (( i = 0; i < ${#HADOOP_USER_PARAMS[@]}; i++ ))
|
||||||
argv=(${argv[@]/stop})
|
do
|
||||||
argv=(${argv[@]/status})
|
if [[ "${HADOOP_USER_PARAMS[$i]}" =~ ^start$ ]] ||
|
||||||
|
[[ "${HADOOP_USER_PARAMS[$i]}" =~ ^stop$ ]] ||
|
||||||
|
[[ "${HADOOP_USER_PARAMS[$i]}" =~ ^status$ ]]; then
|
||||||
|
unset HADOOP_USER_PARAMS[$i]
|
||||||
|
fi
|
||||||
|
done
|
||||||
|
|
||||||
${hdfsscript} --slaves --daemon "${daemonmode}" "${argv[@]}"
|
${hdfsscript} --slaves --daemon "${daemonmode}" "${HADOOP_USER_PARAMS[@]}"
|
||||||
|
|
|
@ -415,7 +415,19 @@ function hadoop_common_slave_mode_execute
|
||||||
|
|
||||||
# if --slaves is still on the command line, remove it
|
# if --slaves is still on the command line, remove it
|
||||||
# to prevent loops
|
# to prevent loops
|
||||||
argv=(${argv[@]/--slaves})
|
# Also remove --hostnames and --hosts along with arg values
|
||||||
|
local argsSize=${#argv[@]};
|
||||||
|
for (( i = 0; i < $argsSize; i++ ))
|
||||||
|
do
|
||||||
|
if [[ "${argv[$i]}" =~ ^--slaves$ ]]; then
|
||||||
|
unset argv[$i]
|
||||||
|
elif [[ "${argv[$i]}" =~ ^--hostnames$ ]] ||
|
||||||
|
[[ "${argv[$i]}" =~ ^--hosts$ ]]; then
|
||||||
|
unset argv[$i];
|
||||||
|
let i++;
|
||||||
|
unset argv[$i];
|
||||||
|
fi
|
||||||
|
done
|
||||||
hadoop_connect_to_hosts -- "${argv[@]}"
|
hadoop_connect_to_hosts -- "${argv[@]}"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -55,9 +55,14 @@ hadoop_error "WARNING: Attempting to execute replacement \"yarn --slaves --daemo
|
||||||
# we're going to turn this into
|
# we're going to turn this into
|
||||||
# yarn --slaves --daemon (start|stop) (rest of options)
|
# yarn --slaves --daemon (start|stop) (rest of options)
|
||||||
#
|
#
|
||||||
argv=(${HADOOP_USER_PARAMS[@]/start})
|
for (( i = 0; i < ${#HADOOP_USER_PARAMS[@]}; i++ ))
|
||||||
argv=(${argv[@]/stop})
|
do
|
||||||
argv=(${argv[@]/status})
|
if [[ "${HADOOP_USER_PARAMS[$i]}" =~ ^start$ ]] ||
|
||||||
|
[[ "${HADOOP_USER_PARAMS[$i]}" =~ ^stop$ ]] ||
|
||||||
|
[[ "${HADOOP_USER_PARAMS[$i]}" =~ ^status$ ]]; then
|
||||||
|
unset HADOOP_USER_PARAMS[$i]
|
||||||
|
fi
|
||||||
|
done
|
||||||
|
|
||||||
${yarnscript} --slaves --daemon "${daemonmode}" "${argv[@]}"
|
${yarnscript} --slaves --daemon "${daemonmode}" "${HADOOP_USER_PARAMS[@]}"
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue