You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2014/03/17 23:02:51 UTC
git commit: updated refs/heads/trunk to 4d227c2
Repository: giraph
Updated Branches:
refs/heads/trunk 6d603ec7d -> 4d227c289
GIRAPH-869: Log Vertex/Edge Count for All Workers (yhdong via majakabiljo)
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/4d227c28
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/4d227c28
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/4d227c28
Branch: refs/heads/trunk
Commit: 4d227c289ad98c3ff58e49812b47bdea92976c39
Parents: 6d603ec
Author: Maja Kabiljo <ma...@fb.com>
Authored: Mon Mar 17 15:01:34 2014 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Mon Mar 17 15:01:34 2014 -0700
----------------------------------------------------------------------
CHANGELOG | 2 ++
.../java/org/apache/giraph/partition/PartitionUtils.java | 8 ++++++++
2 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/4d227c28/CHANGELOG
----------------------------------------------------------------------
diff --git a/CHANGELOG b/CHANGELOG
index c241971..360e0f8 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,6 +1,8 @@
Giraph Change Log
Release 1.1.0 - unreleased
+ GIRAPH-869: Log Vertex/Edge Count for All Workers (yhdong via majakabiljo)
+
GIRAPH-868: Fix race condition with WorkerProgress (majakabiljo)
GIRAPH-867: Fix comments in PageRankComputation (ssc)
http://git-wip-us.apache.org/repos/asf/giraph/blob/4d227c28/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java b/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
index 68bc2de..4600745 100644
--- a/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
+++ b/giraph-core/src/main/java/org/apache/giraph/partition/PartitionUtils.java
@@ -133,6 +133,14 @@ public class PartitionUtils {
Lists.newArrayList(workerStatsMap.entrySet());
if (LOG.isInfoEnabled()) {
+ StringBuilder sb = new StringBuilder();
+ for (Entry<WorkerInfo, VertexEdgeCount> worker : workerEntryList) {
+ sb.append(worker.getKey());
+ sb.append(":");
+ sb.append(worker.getValue());
+ sb.append(",");
+ }
+ LOG.info("analyzePartitionStats: [" + sb + "]");
Collections.sort(workerEntryList, new VertexCountComparator());
LOG.info("analyzePartitionStats: Vertices - Mean: " +
(totalVertexEdgeCount.getVertexCount() /