apache-spark - Spark-提交 CoarseGrainedExecutorBackend 错误

Question

我有一个使用 Python 编写的非常简单的 spark 代码。我尝试在独立集群中运行此代码。

from __future__ import print_function

from pyspark import SparkConf
from pyspark import SparkContext

if __name__ == "__main__":

    conf = SparkConf().setAppName("deneme").setMaster("spark://spark-master:7077")
    sc = SparkContext(conf=conf)

    data = [1, 2, 3, 4, 5]
    distData = sc.parallelize(data)
    distData.foreach(print)

我运行以下命令的代码：

spark-submit --master://spark-master:7077 abc.py

结果显示在工作节点的 stderr 页面中。它还在 stderr 页面中显示错误。

ERROR executor.CoarseGrainedExecutorBackend: RECEIVED SIGNAL TERM

我知道这是一个非常简单的例子，但我找不到任何解决方案。

标签： apache-sparkpyspark