diff --git a/bin/interpreter.sh b/bin/interpreter.sh index cc35182fb1..ff4b75b66e 100755 --- a/bin/interpreter.sh +++ b/bin/interpreter.sh @@ -77,6 +77,9 @@ if [[ "${INTERPRETER_ID}" == "spark" ]]; then 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} + + export PYTHONPATH="$SPARK_HOME/python/:$PYTHONPATH" + export PYTHONPATH="$SPARK_HOME/python/lib/py4j-0.8.2.1-src.zip:$PYTHONPATH" else # add Hadoop jars into classpath if [[ -n "${HADOOP_HOME}" ]]; then