Repository: mahout Updated Branches: refs/heads/master 5d56be7f3 -> 401c8e8b4
MAHOUT-1807: Distributed second norm doesn't take sqrt closes apache/mahout#189 Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/401c8e8b Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/401c8e8b Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/401c8e8b Branch: refs/heads/master Commit: 401c8e8b4a40accc0d41fe8f3c4ee55dfba0040d Parents: 5d56be7 Author: Andrew Palumbo <[email protected]> Authored: Tue Mar 15 12:44:10 2016 -0400 Committer: Andrew Palumbo <[email protected]> Committed: Tue Mar 15 12:44:52 2016 -0400 ---------------------------------------------------------------------- .../main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/401c8e8b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala index 3200288..6b08c1f 100644 --- a/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala +++ b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala @@ -86,12 +86,12 @@ object SparkEngine extends DistributedEngine { if (drm.nrow == 0) drm.colSums() else drm.colSums() /= drm.nrow override def norm[K](drm: CheckpointedDrm[K]): Double = - drm.rdd + math.sqrt(drm.rdd // Compute sum of squares of each vector .map { case (key, v) â v dot v } - .reduce(_ + _) + .reduce(_ + _)) /** Optional engine-specific all reduce tensor operation. */
