我正在尝试在 Anaconda 中导入 pyspark 并运行示例代码。但是,每当我尝试在 Anaconda 中运行代码时,都会收到以下错误消息。
错误:py4j.java_gateway:尝试连接到 Java 服务器时出错 (127.0.0.1:53294) 回溯(最近一次调用):文件“C:\spark\python\lib\py4j-0.10.3-src .zip\py4j\java_gateway.py", line 1021, in send_command self.socket.sendall(command.encode("utf-8")) ConnectionResetError: [WinError 10054] 一个现有的连接被远程主机强行关闭
在处理上述异常的过程中,又发生了一个异常:
回溯(最近一次调用):文件“C:\spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”,第 883 行,在 send_command 响应 = connection.send_command(command) 文件中“C:\spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”,第 1025 行,在 send_command “发送时出错”,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 connection = self.deque.pop() IndexError:从空双端队列弹出
在处理上述异常的过程中,又发生了一个异常:
回溯(最近一次调用):文件“C:\spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”,第 963 行,在 start self.socket.connect((self.地址,self.port)) ConnectionRefusedError: [WinError 10061] 无法建立连接,因为目标机器主动拒绝它 ERROR:py4j.java_gateway:An error occurred while try to connect to the Java server (127.0.0.1:53294) Traceback (最近一次通话):文件“C:\spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”,第 827 行,_get_connection connection = self.deque.pop() IndexError : 从空的双端队列中弹出
在处理上述异常的过程中,又发生了一个异常:
回溯(最近一次调用):文件“C:\spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”,第 963 行,在 start …