|
@@ -76,8 +76,8 @@ shift
|
|
|
case "${COMMAND}" in
|
|
|
application|applicationattempt|container)
|
|
|
CLASS=org.apache.hadoop.yarn.client.cli.ApplicationCLI
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
set -- "${COMMAND}" "$@"
|
|
|
;;
|
|
|
classpath)
|
|
@@ -85,13 +85,13 @@ case "${COMMAND}" in
|
|
|
;;
|
|
|
daemonlog)
|
|
|
CLASS=org.apache.hadoop.log.LogLevel
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
jar)
|
|
|
CLASS=org.apache.hadoop.util.RunJar
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
historyserver)
|
|
|
supportdaemonization="true"
|
|
@@ -102,19 +102,19 @@ case "${COMMAND}" in
|
|
|
;;
|
|
|
logs)
|
|
|
CLASS=org.apache.hadoop.yarn.client.cli.LogsCLI
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
node)
|
|
|
CLASS=org.apache.hadoop.yarn.client.cli.NodeCLI
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
nodemanager)
|
|
|
supportdaemonization="true"
|
|
|
CLASS='org.apache.hadoop.yarn.server.nodemanager.NodeManager'
|
|
|
- hadoop_debug "Append YARN_NODEMANAGER_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_NODEMANAGER_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_NODEMANAGER_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_NODEMANAGER_OPTS}"
|
|
|
# Backwards compatibility
|
|
|
if [[ -n "${YARN_NODEMANAGER_HEAPSIZE}" ]]; then
|
|
|
HADOOP_HEAPSIZE_MAX="${YARN_NODEMANAGER_HEAPSIZE}"
|
|
@@ -123,8 +123,8 @@ case "${COMMAND}" in
|
|
|
proxyserver)
|
|
|
supportdaemonization="true"
|
|
|
CLASS='org.apache.hadoop.yarn.server.webproxy.WebAppProxyServer'
|
|
|
- hadoop_debug "Append YARN_PROXYSERVER_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_PROXYSERVER_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_PROXYSERVER_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_PROXYSERVER_OPTS}"
|
|
|
# Backwards compatibility
|
|
|
if [[ -n "${YARN_PROXYSERVER_HEAPSIZE}" ]]; then
|
|
|
HADOOP_HEAPSIZE_MAX="${YARN_PROXYSERVER_HEAPSIZE}"
|
|
@@ -132,14 +132,14 @@ case "${COMMAND}" in
|
|
|
;;
|
|
|
queue)
|
|
|
CLASS=org.apache.hadoop.yarn.client.cli.QueueCLI
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
resourcemanager)
|
|
|
supportdaemonization="true"
|
|
|
CLASS='org.apache.hadoop.yarn.server.resourcemanager.ResourceManager'
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_RESOURCEMANAGER_OPTS}"
|
|
|
- hadoop_debug "Append YARN_RESOURCEMANAGER_OPTS onto YARN_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_RESOURCEMANAGER_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_RESOURCEMANAGER_OPTS onto HADOOP_OPTS"
|
|
|
# Backwards compatibility
|
|
|
if [[ -n "${YARN_RESOURCEMANAGER_HEAPSIZE}" ]]; then
|
|
|
HADOOP_HEAPSIZE_MAX="${YARN_RESOURCEMANAGER_HEAPSIZE}"
|
|
@@ -147,25 +147,25 @@ case "${COMMAND}" in
|
|
|
;;
|
|
|
rmadmin)
|
|
|
CLASS='org.apache.hadoop.yarn.client.cli.RMAdminCLI'
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
scmadmin)
|
|
|
CLASS='org.apache.hadoop.yarn.client.SCMAdmin'
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
sharedcachemanager)
|
|
|
supportdaemonization="true"
|
|
|
CLASS='org.apache.hadoop.yarn.server.sharedcachemanager.SharedCacheManager'
|
|
|
- hadoop_debug "Append YARN_SHAREDCACHEMANAGER_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_SHAREDCACHEMANAGER_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_SHAREDCACHEMANAGER_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_SHAREDCACHEMANAGER_OPTS}"
|
|
|
;;
|
|
|
timelineserver)
|
|
|
supportdaemonization="true"
|
|
|
CLASS='org.apache.hadoop.yarn.server.applicationhistoryservice.ApplicationHistoryServer'
|
|
|
- hadoop_debug "Append YARN_TIMELINESERVER_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_TIMELINESERVER_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_TIMELINESERVER_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_TIMELINESERVER_OPTS}"
|
|
|
# Backwards compatibility
|
|
|
if [[ -n "${YARN_TIMELINESERVER_HEAPSIZE}" ]]; then
|
|
|
HADOOP_HEAPSIZE_MAX="${YARN_TIMELINESERVER_HEAPSIZE}"
|
|
@@ -173,8 +173,8 @@ case "${COMMAND}" in
|
|
|
;;
|
|
|
version)
|
|
|
CLASS=org.apache.hadoop.util.VersionInfo
|
|
|
- hadoop_debug "Append YARN_CLIENT_OPTS onto YARN_OPTS"
|
|
|
- YARN_OPTS="${YARN_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
+ hadoop_debug "Append YARN_CLIENT_OPTS onto HADOOP_OPTS"
|
|
|
+ HADOOP_OPTS="${HADOOP_OPTS} ${YARN_CLIENT_OPTS}"
|
|
|
;;
|
|
|
*)
|
|
|
CLASS="${COMMAND}"
|
|
@@ -186,36 +186,25 @@ esac
|
|
|
|
|
|
hadoop_verify_user "${COMMAND}"
|
|
|
|
|
|
-# set HADOOP_OPTS to YARN_OPTS so that we can use
|
|
|
-# finalize, etc, without doing anything funky
|
|
|
-hadoop_debug "Resetting HADOOP_OPTS=YARN_OPTS"
|
|
|
-# shellcheck disable=SC2034
|
|
|
-HADOOP_OPTS="${YARN_OPTS}"
|
|
|
-
|
|
|
daemon_outfile="${HADOOP_LOG_DIR}/hadoop-${HADOOP_IDENT_STRING}-${COMMAND}-${HOSTNAME}.out"
|
|
|
daemon_pidfile="${HADOOP_PID_DIR}/hadoop-${HADOOP_IDENT_STRING}-${COMMAND}.pid"
|
|
|
|
|
|
if [[ "${HADOOP_DAEMON_MODE}" != "default" ]]; then
|
|
|
# shellcheck disable=SC2034
|
|
|
HADOOP_ROOT_LOGGER="${HADOOP_DAEMON_ROOT_LOGGER}"
|
|
|
- YARN_ROOT_LOGGER="${HADOOP_DAEMON_ROOT_LOGGER}"
|
|
|
HADOOP_LOGFILE="hadoop-${HADOOP_IDENT_STRING}-${COMMAND}-${HOSTNAME}.log"
|
|
|
fi
|
|
|
|
|
|
# Add YARN custom options to comamnd line in case someone actaully
|
|
|
# used these.
|
|
|
-#
|
|
|
-# Note that we are replacing ' ' with '\ ' so that when we exec
|
|
|
-# stuff it works
|
|
|
-#
|
|
|
YARN_LOG_DIR=$HADOOP_LOG_DIR
|
|
|
hadoop_translate_cygwin_path YARN_LOG_DIR
|
|
|
-hadoop_add_param HADOOP_OPTS yarn.log.dir "-Dyarn.log.dir=${YARN_LOG_DIR/ /\ }"
|
|
|
-hadoop_add_param HADOOP_OPTS yarn.log.file "-Dyarn.log.file=${HADOOP_LOGFILE/ /\ }"
|
|
|
+hadoop_add_param HADOOP_OPTS yarn.log.dir "-Dyarn.log.dir=${YARN_LOG_DIR}"
|
|
|
+hadoop_add_param HADOOP_OPTS yarn.log.file "-Dyarn.log.file=${HADOOP_LOGFILE}"
|
|
|
YARN_HOME_DIR=$HADOOP_YARN_HOME
|
|
|
hadoop_translate_cygwin_path YARN_HOME_DIR
|
|
|
-hadoop_add_param HADOOP_OPTS yarn.home.dir "-Dyarn.home.dir=${YARN_HOME_DIR/ /\ }"
|
|
|
-hadoop_add_param HADOOP_OPTS yarn.root.logger "-Dyarn.root.logger=${YARN_ROOT_LOGGER:-INFO,console}"
|
|
|
+hadoop_add_param HADOOP_OPTS yarn.home.dir "-Dyarn.home.dir=${YARN_HOME_DIR}"
|
|
|
+hadoop_add_param HADOOP_OPTS yarn.root.logger "-Dyarn.root.logger=${HADOOP_ROOT_LOGGER:-INFO,console}"
|
|
|
|
|
|
hadoop_finalize
|
|
|
|