pyspark报错Exception: Java gateway process exited before sending its port number解决方法

Posted 2021-02-01 温良Miner

1.问题

搭建spark的python环境好后简单使用，源代码如下：

然后就给我丢了一堆错误：

 2.解决办法

 这里指定一下Java的环境就可以了，添加代码：

import os
os.environ[\'JAVA_HOME\'] = \'D:\\JavaJDK\'  # 这里的路径为java的bin目录所在路径

这里指定一下Java的bin目录所在路径，读者根据个人安装目录修改，完美解决！

 3.结果

问题解决，运行没有报错！