From 9058f261fe6ba7c7889808e124ec2bd8f37f99f5 Mon Sep 17 00:00:00 2001
From: "Joseph E. Gonzalez" <joseph.e.gonzalez@gmail.com>
Date: Tue, 15 Oct 2013 17:39:09 -0700
Subject: [PATCH] Addressing issue where statistics are not computed correctly

---
 .../src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala
index d373d86a5a..aa0aaaaef4 100644
--- a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala
+++ b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala
@@ -146,7 +146,7 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected (
     val replicationRatio = 
       vid2pid.groupByKey().map(kv => kv._2.size).sum / vTable.count
     val loadArray = 
-      eTable.map{ case (pid, epart) => epart.data.size }.collect.map(x => x / numEdges)
+      eTable.map{ case (pid, epart) => epart.data.size }.collect.map(x => x.toDouble / numEdges)
     val minLoad = loadArray.min
     val maxLoad = loadArray.max
     Map(