这篇文章给大家介绍运行独立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错误的解决办法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。