Updated Branches: refs/heads/trunk 799824014 -> ea831c80b
GIRAPH-554: Set PartitionContext in InternalVertexRunner (majakabiljo) Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/ea831c80 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/ea831c80 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/ea831c80 Branch: refs/heads/trunk Commit: ea831c80b8cfd33a233a34666537f840f2c104bf Parents: 7998240 Author: Maja Kabiljo <[email protected]> Authored: Mon Mar 11 21:21:58 2013 -0700 Committer: Maja Kabiljo <[email protected]> Committed: Mon Mar 11 21:21:58 2013 -0700 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../apache/giraph/utils/InternalVertexRunner.java | 3 +++ 2 files changed, 5 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/ea831c80/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index 90d626f..9ca3b3b 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 0.2.0 - unreleased + GIRAPH-554: Set PartitionContext in InternalVertexRunner (majakabiljo) + GIRAPH-559: Giraph build breaks (nitay) GIRAPH-550: HiveVertexReader should call initialize, not users (nitay) http://git-wip-us.apache.org/repos/asf/giraph/blob/ea831c80/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java b/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java index 7848d1c..7989483 100644 --- a/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java +++ b/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java @@ -138,6 +138,9 @@ public class InternalVertexRunner { if (classes.hasWorkerContextClass()) { conf.setWorkerContextClass(classes.getWorkerContextClass()); } + if (classes.hasPartitionContextClass()) { + conf.setMasterComputeClass(classes.getPartitionContextClass()); + } if (classes.hasCombinerClass()) { conf.setVertexCombinerClass(classes.getCombinerClass()); }
