From a2b1e5720266393a1813f0abe43c3709ebf46268 Mon Sep 17 00:00:00 2001 From: sboeschhuawei Date: Sun, 25 Jan 2015 03:21:43 -0800 Subject: [PATCH] Revert inadvertent update to KMeans --- .../main/scala/org/apache/spark/mllib/clustering/KMeans.scala | 1 - 1 file changed, 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 index 805dd46b08960..11633e8242313 100644 --- 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) =>