Revert inadvertent update to KMeans

freeman-lab · Jan 25, 2015 · a2b1e57 · a2b1e57
1 parent 9294263
commit a2b1e57
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala
@@ -131,7 +131,6 @@ class KMeans private (
     }
 
     // Compute squared norms and cache them.
-    val collected = data.collect()
     val norms = data.map(Vectors.norm(_, 2.0))
     norms.persist()
     val zippedData = data.zip(norms).map { case (v, norm) =>