Revert inadvertent update to KMeans

sboeschhuawei · sboeschhuawei · commit a2b1e5720266 · 2015-01-25T03:21:43.000-08:00
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) =>

Original file line number	Diff line number	Diff line change
`@@ -131,7 +131,6 @@ class KMeans private (`
`131`	`131`	`}`
`132`	`132`
`133`	`133`	`// Compute squared norms and cache them.`
`134`		`- val collected = data.collect()`
`135`	`134`	`val norms = data.map(Vectors.norm(_, 2.0))`
`136`	`135`	`norms.persist()`
`137`	`136`	`val zippedData = data.zip(norms).map { case (v, norm) =>`