Ich habe gerade ein seltsames Problem mit Spark (pyspark) auf DSE-Cluster 4.8. Aus irgendeinem Grund, wenn der Job ausgeführt wird, habe ich einige Fehler, wie unten beschrieben. Weiß jemand irgendeinen Weg, diesen Fehler irgendwie zu schließen?Fehler beim Ausführen eines Python-Jobs im DSE 4.8 Spark-Cluster.
Ich verwende den dse spark-submit
Befehl.
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
Ok, es scheint ein Speicherproblem. Grundsätzlich, wenn der Executor Speicher ausläßt, beginnen die Fehler zu erscheinen. – jguerra