我剛剛在DSE cluster 4.8上運行Spark(pyspark)時出現了一個奇怪的問題。出於某種原因,當作業運行時,我得到了幾十個錯誤,如下所述。無論如何,任何人都知道有什麼辦法來關閉這個錯誤?在DSE 4.8 Spark羣集上運行Python作業時出錯。
我正在使用dse spark-submit
命令。
ERROR 2016-04-04 12:49:21,305 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend: Asked to remove non-existent executor 747
ERROR 2016-04-04 12:49:21,305 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend: Asked to remove non-existent executor 748
ERROR 2016-04-04 12:49:21,347 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend: Asked to remove non-existent executor 749
ERROR 2016-04-04 12:49:21,388 org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend: Asked to remove non-existent executor 750
好吧,它似乎是一個內存問題。基本上當執行器耗盡內存時,錯誤開始彈出。 – jguerra