Skip to content

Commit 86e217f

Browse files
committed
added cache to DT input
1 parent e3c84cc commit 86e217f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

mllib/src/main/scala/org/apache/spark/mllib/tree/DecisionTree.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ class DecisionTree (private val strategy: Strategy) extends Serializable with Lo
220220
*/
221221

222222
timer.reset()
223-
val treeInput = TreePoint.convertToTreeRDD(retaggedInput, bins, metadata)
223+
val treeInput = TreePoint.convertToTreeRDD(retaggedInput, bins, metadata).cache()
224224
timer.initTime += timer.elapsed()
225225

226226
// depth of the decision tree

0 commit comments

Comments
 (0)