--amend

prabeesh · Jul 17, 2015 · 7f62a55 · 7f62a55
1 parent c62cb1e
commit 7f62a55
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
@@ -400,7 +400,7 @@ final class OnlineLDAOptimizer extends LDAOptimizer {
         while (meanchange > 1e-3) {
           val lastgamma = gammad.copy
           //        K                  K * ids               ids
-          gammad := (expElogthetad :* (expElogbetad.t * (ctsVector / phinorm))) :+ alpha
+          gammad := (expElogthetad :* (expElogbetad.t * (ctsVector :/ phinorm))) :+ alpha
           expElogthetad := exp(digamma(gammad) - digamma(sum(gammad)))
           phinorm := expElogbetad * expElogthetad :+ 1e-100
           meanchange = sum(abs(gammad - lastgamma)) / k