You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by Ascot Moss <as...@gmail.com> on 2016/07/15 12:02:54 UTC

Random Forest Job got killed (DAGScheduler: failed: Set() , DecisionTree.scala:642), which has no missing parents)

Hi,

I am trying to create the Random Forest model, my source_code as follows:
val rf_model  = edhRF.trainClassifier(trainData, 7, Map[Int,Int](), 20,
"auto", "entropy", 30, 300)


I got following error:

######

16/07/15 19:55:04 INFO TaskSchedulerImpl: Removed TaskSet 21.0, whose tasks
have all completed, from pool

16/07/15 19:55:04 INFO DAGScheduler: ShuffleMapStage 21 (mapPartitions at
DecisionTree.scala:622) finished in 2.685 s

16/07/15 19:55:04 INFO DAGScheduler: looking for newly runnable stages

16/07/15 19:55:04 INFO DAGScheduler: running: Set()

16/07/15 19:55:04 INFO DAGScheduler: waiting: Set(ResultStage 22)

16/07/15 19:55:04 INFO DAGScheduler: failed: Set()

16/07/15 19:55:04 INFO DAGScheduler: Submitting ResultStage 22
(MapPartitionsRDD[43] at map at DecisionTree.scala:642), which has no
missing parents

Killed

######


Any idea what is wrong?

Regards