Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-8688] Remove "hadoop classpath" from config.sh #5502

Closed
wants to merge 1 commit into from
Closed

[FLINK-8688] Remove "hadoop classpath" from config.sh #5502

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 1 addition & 24 deletions flink-dist/src/main/flink-bin/bin/config.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -368,31 +368,8 @@ fi

INTERNAL_HADOOP_CLASSPATHS="${HADOOP_CLASSPATH}:${HADOOP_CONF_DIR}:${YARN_CONF_DIR}"

# check if the "hadoop" binary is available, if yes, use that to augment the CLASSPATH
if command -v hadoop >/dev/null 2>&1; then
echo "Using the result of 'hadoop classpath' to augment the Hadoop classpath: `hadoop classpath`"
INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:`hadoop classpath`"
fi

if [ -n "${HBASE_CONF_DIR}" ]; then
# Look for hbase command in HBASE_HOME or search PATH.
if [ -n "${HBASE_HOME}" ]; then
HBASE_PATH="${HBASE_HOME}/bin"
HBASE_COMMAND=`command -v "${HBASE_PATH}/hbase"`
else
HBASE_PATH=$PATH
HBASE_COMMAND=`command -v hbase`
fi

# Whether the hbase command was found.
if [[ $? -eq 0 ]]; then
# Setup the HBase classpath. We add the HBASE_CONF_DIR last to ensure the right config directory is used.
INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:`${HBASE_COMMAND} classpath`:${HBASE_CONF_DIR}"
else
echo "HBASE_CONF_DIR=${HBASE_CONF_DIR} is set but 'hbase' command was not found in ${HBASE_PATH} so classpath could not be updated."
fi

unset HBASE_COMMAND HBASE_PATH
INTERNAL_HADOOP_CLASSPATHS="${INTERNAL_HADOOP_CLASSPATHS}:${HBASE_CONF_DIR}"
fi

# Auxilliary function which extracts the name of host from a line which
Expand Down