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 <[email protected]> Authored: Mon Mar 17 15:01:34 2014 -0700 Committer: Maja Kabiljo <[email protected]> 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() /
