运行独立 pyspark 时出现 Windows 错误解决办法

我正在尝试在 anaconda 中导入 pyspark 并运行示例代码。但是，每当我尝试在 anaconda 中运行代码时，都会收到以下错误消息。

尝试连接到 java 服务器时发生 error:py4j.java_gateway:an 错误(127.0.0.1:53294)追溯(最近一次调用最近)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 send_command self.socket.sendall(command.encode(“ utf-8”) )) connectionreseterror：[1]远程主机强行关闭了现有连接

在处理上述异常期间，发生了另一个异常：

追溯(最近一次通话最近)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，第 883 行，在 send_command response = connection.send_command(command)文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\send_command 行中的“ java_gateway.py”，第 1025 行，“发送时出错”，e，proto.error_on_send)py4j.protocol.py4jnetworkerror：发送时出错

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，第 827 行，在_get_connection 连接= self.deque.pop() indexerror：从空双端队列弹出

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：在开始 self.socket.connect((self.address，self.port))中的文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 connectionrefusederror：[2]无法建立连接，因为目标计算机被主动拒绝尝试连接到 java 服务器(127.0.0.1:53294)回溯时发生 error:py4j.java_gateway:an 错误(最近一次调用为最新)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() indexerror ：从空双端队列弹出

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：在开始 self.socket.connect((self.address，self.port))中的文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 connectionrefusederror：[3]无法建立连接，因为目标计算机被主动拒绝尝试连接到 java 服务器(127.0.0.1:53294)回溯时发生 error:py4j.java_gateway:an 错误(最近一次调用为最新)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() indexerror ：从空双端队列弹出

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：在开始 self.socket.connect((self.address，self.port))中的文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”(行 963)connectionrefusederror：[4]无法建立连接，因为目标计算机被主动拒绝尝试连接到 java 服务器(127.0.0.1:53294)回溯时发生 error:py4j.java_gateway:an 错误(最近一次调用为最新)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() indexerror ：从空双端队列弹出

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：在开始 self.socket.connect((self.address，self.port))中的文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 connectionrefusederror：[5]无法建立连接，因为目标计算机被主动拒绝尝试连接到 java 服务器(127.0.0.1:53294)回溯时发生 error:py4j.java_gateway:an 错误(最近一次调用为最新)：文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() indexerror ：从空双端队列弹出

在处理上述异常期间，发生了另一个异常：

追溯(最近一次呼叫最近)：在开始 self.socket.connect((self.address，self.port))中的文件“ c：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 connectionrefusederror：[6]无法建立连接，因为目标计算机被主动拒绝它重新加载了模块：py4j.protocol，pyspark.sql.context，py4j.java_gateway，py4j.compat，pyspark.profiler，pyspark.sql.catalog，pyspark.context，pyspark.sql.group，pyspark.sql.conf，pyspark.sql.readwriter，pyspark.resultiterable，pyspark.sql，pyspark.sql.dataframe，pyspark.traceback_utils，pyspark.cloudpickle，pyspark.rddsampler，pyspark.accumulators，，pyspark.broadcast，pyspark.broadcast，pyspark.broadcast，pyspark.broadcast pyspark.conf，pyspark.serializers，pyspark.files，pyspark.join，pyspark.sql.streaming，pyspark.shuffle，pyspark，py4j.version，pyspark.sql.session，pyspark.sql.column，py4j.finalizer，py4j.java_collections，pyspark.status，pyspark.sql.window，pyspark.sql.utils，pyspark.storagelevel，pyspark.heapq3，py4j.signals，最近的回访()

文件“”，第 1 行，位于 runfile('c:/users/hlee/desktop/pyspark.py'，wdir ='c:/users/hlee/desktop')

到此这篇关于运行独立 pyspark 时出现 windows 错误解决办法的文章就介绍到这了,更多相关运行独立 pyspark 时出现 windows 错误内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！