我正在嘗試在 Anaconda 中導(dǎo)入 pyspark 并運(yùn)行示例代碼。但是，每當(dāng)我嘗試在 Anaconda 中運(yùn)行代碼時(shí)，都會(huì)收到以下錯(cuò)誤消息。

嘗試連接到 Java 服務(wù)器時(shí)發(fā)生 ERROR:py4j.java_gateway:An 錯(cuò)誤(127.0.0.1:53294)追溯(最近一次調(diào)用最近)：文件“ 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]遠(yuǎn)程主機(jī)強(qiáng)行關(guān)閉了現(xiàn)有連接

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次通話最近)：文件“ 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 行，“發(fā)送時(shí)出錯(cuò)”，e，proto.ERROR_ON_SEND)py4j.protocol.Py4JNetworkError：發(fā)送時(shí)出錯(cuò)

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，第 827 行，在_get_connection 連接= self.deque.pop() IndexError：從空雙端隊(duì)列彈出

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：在開(kāi)始 self.socket.connect((self.address，self.port))中的文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 ConnectionRefusedError：[2]無(wú)法建立連接，因?yàn)槟繕?biāo)計(jì)算機(jī)被主動(dòng)拒絕嘗試連接到 Java 服務(wù)器(127.0.0.1:53294)回溯時(shí)發(fā)生 ERROR:py4j.java_gateway:An 錯(cuò)誤(最近一次調(diào)用為最新)：文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() IndexError ：從空雙端隊(duì)列彈出

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：在開(kāi)始 self.socket.connect((self.address，self.port))中的文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 ConnectionRefusedError：[3]無(wú)法建立連接，因?yàn)槟繕?biāo)計(jì)算機(jī)被主動(dòng)拒絕嘗試連接到 Java 服務(wù)器(127.0.0.1:53294)回溯時(shí)發(fā)生 ERROR:py4j.java_gateway:An 錯(cuò)誤(最近一次調(diào)用為最新)：文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() IndexError ：從空雙端隊(duì)列彈出

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：在開(kāi)始 self.socket.connect((self.address，self.port))中的文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”(行 963)ConnectionRefusedError：[4]無(wú)法建立連接，因?yàn)槟繕?biāo)計(jì)算機(jī)被主動(dòng)拒絕嘗試連接到 Java 服務(wù)器(127.0.0.1:53294)回溯時(shí)發(fā)生 ERROR:py4j.java_gateway:An 錯(cuò)誤(最近一次調(diào)用為最新)：文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() IndexError ：從空雙端隊(duì)列彈出

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：在開(kāi)始 self.socket.connect((self.address，self.port))中的文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 ConnectionRefusedError：[5]無(wú)法建立連接，因?yàn)槟繕?biāo)計(jì)算機(jī)被主動(dòng)拒絕嘗試連接到 Java 服務(wù)器(127.0.0.1:53294)回溯時(shí)發(fā)生 ERROR:py4j.java_gateway:An 錯(cuò)誤(最近一次調(diào)用為最新)：文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 827，在_get_connection connection = self.deque.pop() IndexError ：從空雙端隊(duì)列彈出

在處理上述異常期間，發(fā)生了另一個(gè)異常：

追溯(最近一次呼叫最近)：在開(kāi)始 self.socket.connect((self.address，self.port))中的文件“ C：\ spark\python\lib\py4j-0.10.3-src.zip\py4j\java_gateway.py”，行 963 ConnectionRefusedError：[6]無(wú)法建立連接，因?yàn)槟繕?biāo)計(jì)算機(jī)被主動(dòng)拒絕它重新加載了模塊：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')

到此這篇關(guān)于運(yùn)行獨(dú)立 pyspark 時(shí)出現(xiàn) Windows 錯(cuò)誤解決辦法的文章就介紹到這了,更多相關(guān)運(yùn)行獨(dú)立 pyspark 時(shí)出現(xiàn) Windows 錯(cuò)誤內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論