make RDD.unpersist blocking called

apache · Jul 21, 2016 · 3d8c60d · 3d8c60d
1 parent e5ed33b
commit 3d8c60d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala
@@ -478,7 +478,7 @@ final class OnlineLDAOptimizer extends LDAOptimizer {
       _ += _, _ += _)
     val gammat: BDM[Double] = breeze.linalg.DenseMatrix.vertcat(
       stats.map(_._2).flatMap(list => list).collect().map(_.toDenseMatrix): _*)
-    stats.unpersist(false)
+    stats.unpersist()
     expElogbetaBc.destroy(false)
     val batchResult = statsSum :* expElogbeta.t