Skip to content

Commit 88f7b0f

Browse files
committed
DSP-19969 allow spark executor log to separate file
1 parent 4ad6b43 commit 88f7b0f

File tree

2 files changed

+17
-3
lines changed

2 files changed

+17
-3
lines changed

bin/manager_start.sh

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,15 +27,22 @@ JAVA_OPTS="-XX:MaxDirectMemorySize=$MAX_DIRECT_MEMORY
2727

2828
MAIN="spark.jobserver.JobManager"
2929

30+
if [ "$SEPARATE_EXECUTOR_LOGGING" = "true" ]
31+
then
32+
export EXECUTOR_LOGGING_OPTS=""
33+
else
34+
export EXECUTOR_LOGGING_OPTS="$LOGGING_OPTS"
35+
fi
36+
3037
if [ ! -z $3 ]; then
3138
cmd='$SPARK_HOME/bin/spark-submit --class $MAIN --driver-memory $JOBSERVER_MEMORY
32-
--conf "spark.executor.extraJavaOptions=$LOGGING_OPTS"
39+
--conf "spark.executor.extraJavaOptions=$EXECUTOR_LOGGING_OPTS"
3340
--proxy-user $3
3441
--driver-java-options "$GC_OPTS $JAVA_OPTS $LOGGING_OPTS $CONFIG_OVERRIDES"
3542
$appdir/spark-job-server.jar $1 $2 $conffile'
3643
else
3744
cmd='$SPARK_HOME/bin/spark-submit --class $MAIN --driver-memory $JOBSERVER_MEMORY
38-
--conf "spark.executor.extraJavaOptions=$LOGGING_OPTS"
45+
--conf "spark.executor.extraJavaOptions=$EXECUTOR_LOGGING_OPTS"
3946
--driver-java-options "$GC_OPTS $JAVA_OPTS $LOGGING_OPTS $CONFIG_OVERRIDES"
4047
$appdir/spark-job-server.jar $1 $2 $conffile'
4148
fi

bin/server_start.sh

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,15 @@ if [ -f "$PIDFILE" ] && kill -0 $(cat "$PIDFILE"); then
4343
exit 1
4444
fi
4545

46+
if [ "$SEPARATE_EXECUTOR_LOGGING" = "true" ]
47+
then
48+
export EXECUTOR_LOGGING_OPTS=""
49+
else
50+
export EXECUTOR_LOGGING_OPTS="$LOGGING_OPTS"
51+
fi
52+
4653
cmd='$SPARK_HOME/bin/spark-submit --class $MAIN --driver-memory $JOBSERVER_MEMORY
47-
--conf "spark.executor.extraJavaOptions=$LOGGING_OPTS"
54+
--conf "spark.executor.extraJavaOptions=$EXECUTOR_LOGGING_OPTS"
4855
--driver-java-options "$GC_OPTS $JAVA_OPTS $LOGGING_OPTS $CONFIG_OVERRIDES"
4956
$@ $appdir/spark-job-server.jar $conffile'
5057

0 commit comments

Comments
 (0)