DSEクラスタ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