apache-spark - Apache Spark "Py4JError: Answer from Java side is empty"

标签 apache-spark

我每次都收到这个错误...
我用苏打水...
我的配置文件:

***"spark.driver.memory 65g
spark.python.worker.memory 65g
spark.master local[*]"***

数据量约为5 Gb。
没有关于此错误的其他信息...
有人知道为什么会这样吗?谢谢!
***"ERROR:py4j.java_gateway:Error while sending or receiving.
Traceback (most recent call last):
  File "/data/analytics/Spark1.6.1/python/lib/py4j-0.9-src.zip/py4j/java_gateway.py", line 746, in send_command
    raise Py4JError("Answer from Java side is empty")
Py4JError: Answer from Java side is empty
ERROR:py4j.java_gateway:An error occurred while trying to connect to the Java server
Traceback (most recent call last):
  File "/data/analytics/Spark1.6.1/python/lib/py4j-0.9-src.zip/py4j/java_gateway.py", line 690, in start
    self.socket.connect((self.address, self.port))
  File "/usr/local/anaconda/lib/python2.7/socket.py", line 228, in meth
    return getattr(self._sock,name)(*args)
error: [Errno 111] Connection refused
ERROR:py4j.java_gateway:An error occurred while trying to connect to the Java server
Traceback (most recent call last):
  File "/data/analytics/Spark1.6.1/python/lib/py4j-0.9-src.zip/py4j/java_gateway.py", line 690, in start
    self.socket.connect((self.address, self.port))
  File "/usr/local/anaconda/lib/python2.7/socket.py", line 228, in meth
    return getattr(self._sock,name)(*args)
error: [Errno 111] Connection refused
ERROR:py4j.java_gateway:An error occurred while trying to connect to the Java server
Traceback (most recent call last):
  File "/data/analytics/Spark1.6.1/python/lib/py4j-0.9-src.zip/py4j/java_gateway.py", line 690, in start
    self.socket.connect((self.address, self.port))
  File "/usr/local/anaconda/lib/python2.7/socket.py", line 228, in meth
    return getattr(self._sock,name)(*args)
error: [Errno 111] Connection refused"***

最佳答案

您是否尝试过设置 spark.executor.memoryspark.driver.memory在您的 Spark 配置文件中?

https://stackoverflow.com/a/22742982/5453184了解更多信息。

关于apache-spark - Apache Spark "Py4JError: Answer from Java side is empty",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37252809/

相关文章:

apache-spark - 使用 Kafka 进行 Spark 流式传输 - createDirectStream 与 createStream

scala - columnSimilarities() 返回 Spark 数据框

scala - Spark MLlib/K-Means 直觉

postgresql - 从 postgreSQL 读取 100M 行到 Spark 并写入 parquet

split - 如何在给定每个 RDD 的最大行数且不使用 ID 列的情况下将 RDD 拆分为多个(较小的)RDD

java - 如何将 zip 文件的内容分配给 Spark 中的每个任务?

hadoop - 无法在 CDH 5.7.5 中安装 Spark 2.0

apache-spark - PySpark:将一个数据帧中的数组值与另一个数据帧中的数组值进行比较以获得交集

scala - java.lang.NoSuchMethodError 当 rdd.saveAsTextFile 由 spark-shell

apache-spark - 什么是 DataProcSparkOperator?