mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
export and check SPARK_SUBMIT
This commit is contained in:
parent
a8a3440eb2
commit
4eb0848e09
2 changed files with 2 additions and 2 deletions
|
|
@ -73,7 +73,7 @@ fi
|
|||
# set spark related env variables
|
||||
if [[ "${INTERPRETER_ID}" == "spark" ]]; then
|
||||
if [[ -n "${SPARK_HOME}" ]]; then
|
||||
SPARK_SUBMIT="${SPARK_HOME}/bin/spark-submit"
|
||||
export SPARK_SUBMIT="${SPARK_HOME}/bin/spark-submit"
|
||||
SPARK_APP_JAR="$(ls ${ZEPPELIN_HOME}/interpreter/spark/zeppelin-spark*.jar)"
|
||||
# This will evantually passes SPARK_APP_JAR to classpath of SparkIMain
|
||||
ZEPPELIN_CLASSPATH=${SPARK_APP_JAR}
|
||||
|
|
|
|||
|
|
@ -318,7 +318,7 @@ public class SparkInterpreter extends Interpreter {
|
|||
}
|
||||
|
||||
private boolean useSparkSubmit() {
|
||||
return null != System.getenv("SPARK_HOME");
|
||||
return null != System.getenv("SPARK_SUBMIT");
|
||||
}
|
||||
|
||||
public static String getSystemDefault(
|
||||
|
|
|
|||
Loading…
Reference in a new issue