export and check SPARK_SUBMIT

This commit is contained in:
Lee moon soo 2015-09-04 19:23:13 -07:00
parent a8a3440eb2
commit 4eb0848e09
2 changed files with 2 additions and 2 deletions

View file

@ -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}

View file

@ -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(