Exception: Python in worker has different version 2.6 than that in driver 2.7, PySpark cannot run


Python版本不一致导致的,设置下环境变量即可。

Exception: Python in worker has different version 2.6 than that in driver 2.7, PySpark cannot run with different minor versions.Please check environment variables PYSPARK_PYTHON and PYSPARK_DRIVER_PYTHON are correctly set.

python --version 发现是2.6

echo $PYSPARK_PYTHON 值为空

echo $PYSPARK_DRIVER_PYTHON 值是ipython

which ipython发现路径是

/home/work/envs/python_2.7.13/bin/ipython

设置环境变量,问题解决:

export PYSPARK_PYTHON=/home/work/envs/python_2.7.13/bin/ipython

 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM