From 7e62b55c23316c519fde202ae4414131f044deb5 Mon Sep 17 00:00:00 2001 From: Zheng RuiFeng Date: Thu, 12 May 2016 17:20:44 +0800 Subject: [PATCH] create pr --- .../main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala index bb2ffab0f60f8..0f26ecd4c6308 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala @@ -196,9 +196,7 @@ object SVDPlusPlus { g.unpersist() g = gJoinT3 - // Convert DoubleMatrix to Array[Double]: - val newVertices = g.vertices.mapValues(v => (v._1.toArray, v._2.toArray, v._3, v._4)) - (Graph(newVertices, g.edges), u) + (g, u) } /**