Fix the bug

pdeyhim · Apr 8, 2014 · 7e533f7 · 7e533f7
1 parent 8a5153a
commit 7e533f7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/SVD.scala b/mllib/src/main/scala/org/apache/spark/mllib/linalg/SVD.scala
@@ -289,8 +289,10 @@ class SVD {
     val rows = data.map(entry =>
       (entry.i, (entry.j, entry.mval))).groupByKey()
     println("rows "+rows)
+    rows.foreach{e => println("r "+e)}
     val emits = rows.flatMap {
-      case (rowind, cols) =>
+      case (rowind, colsI) =>
+        val cols = colsI.toList
         cols.flatMap {
           case (colind1, mval1) =>
             cols.map {