File tree Expand file tree Collapse file tree 2 files changed +17
-3
lines changed Expand file tree Collapse file tree 2 files changed +17
-3
lines changed Original file line number Diff line number Diff line change @@ -27,15 +27,22 @@ JAVA_OPTS="-XX:MaxDirectMemorySize=$MAX_DIRECT_MEMORY
2727
2828MAIN=" spark.jobserver.JobManager"
2929
30+ if [ " $SEPARATE_EXECUTOR_LOGGING " = " true" ]
31+ then
32+ EXECUTOR_SETTING=" "
33+ else
34+ EXECUTOR_SETTING=" --conf spark.executor.extraJavaOptions=$LOGGING_OPTS "
35+ fi
36+
3037if [ ! -z $3 ]; then
3138 cmd=' $SPARK_HOME/bin/spark-submit --class $MAIN --driver-memory $JOBSERVER_MEMORY
32- --conf "spark.executor.extraJavaOptions=$LOGGING_OPTS"
39+ $EXECUTOR_SETTING
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'
3643else
3744 cmd=' $SPARK_HOME/bin/spark-submit --class $MAIN --driver-memory $JOBSERVER_MEMORY
38- --conf "spark.executor.extraJavaOptions=$LOGGING_OPTS"
45+ $EXECUTOR_SETTING
3946 --driver-java-options "$GC_OPTS $JAVA_OPTS $LOGGING_OPTS $CONFIG_OVERRIDES"
4047 $appdir/spark-job-server.jar $1 $2 $conffile'
4148fi
Original file line number Diff line number Diff line change @@ -43,8 +43,15 @@ if [ -f "$PIDFILE" ] && kill -0 $(cat "$PIDFILE"); then
4343 exit 1
4444fi
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+
4653cmd=' $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
You can’t perform that action at this time.
0 commit comments