Skip to content

Commit 07b9ebf

Browse files
check SPARK_CONF_DIR instead of checking properties file
1 parent c5a85eb commit 07b9ebf

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

bin/spark-submit

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,11 @@ while (($#)); do
4242
shift
4343
done
4444

45-
DEFAULT_PROPERTIES_FILE="$SPARK_CONF_DIR/spark-defaults.conf"
46-
if [ ! -f "DEFAULT_PROPERTIES_FILE" ]; then
47-
DEFAULT_PROPERTIES_FILE="$SPARK_HOME/conf/spark-defaults.conf"
45+
46+
if [ ! -d "$SPARK_CONF_DIR" ]; then
47+
SPARK_CONF_DIR="$SPARK_HOME/conf"
4848
fi
49+
DEFAULT_PROPERTIES_FILE="$SPARK_CONF_DIR/spark-defaults.conf"
4950
export SPARK_SUBMIT_DEPLOY_MODE=${SPARK_SUBMIT_DEPLOY_MODE:-"client"}
5051
export SPARK_SUBMIT_PROPERTIES_FILE=${SPARK_SUBMIT_PROPERTIES_FILE:-"$DEFAULT_PROPERTIES_FILE"}
5152

bin/spark-submit2.cmd

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,11 @@ set ORIG_ARGS=%*
2424

2525
rem Reset the values of all variables used
2626
set SPARK_SUBMIT_DEPLOY_MODE=client
27-
set SPARK_SUBMIT_PROPERTIES_FILE=%SPARK_CONF_DIR%\spark-defaults.conf
28-
if not exist %SPARK_SUBMIT_PROPERTIES_FILE% (
29-
set SPARK_SUBMIT_PROPERTIES_FILE=%SPARK_HOME%\conf\spark-defaults.conf
27+
28+
if not exist %SPARK_CONF_DIR% (
29+
set SPARK_CONF_DIR=%SPARK_HOME%\conf
3030
)
31+
set SPARK_SUBMIT_PROPERTIES_FILE=%SPARK_CONF_DIR%\spark-defaults.conf
3132
set SPARK_SUBMIT_DRIVER_MEMORY=
3233
set SPARK_SUBMIT_LIBRARY_PATH=
3334
set SPARK_SUBMIT_CLASSPATH=

0 commit comments

Comments
 (0)