You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ac...@apache.org on 2012/02/20 18:26:12 UTC

svn commit: r1291382 - in /incubator/giraph/trunk: CHANGELOG src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java

Author: aching
Date: Mon Feb 20 17:26:11 2012
New Revision: 1291382

URL: http://svn.apache.org/viewvc?rev=1291382&view=rev
Log:
GIRAPH-150: PageRankBenchmark accesses wrong conf after GiraphJob is
created (aching).

Modified:
    incubator/giraph/trunk/CHANGELOG
    incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java

Modified: incubator/giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/incubator/giraph/trunk/CHANGELOG?rev=1291382&r1=1291381&r2=1291382&view=diff
==============================================================================
--- incubator/giraph/trunk/CHANGELOG (original)
+++ incubator/giraph/trunk/CHANGELOG Mon Feb 20 17:26:11 2012
@@ -1,6 +1,9 @@
 Giraph Change Log
 
 Release 0.2.0 - unreleased
+
+  GIRAPH-150: PageRankBenchmark accesses wrong conf after GiraphJob is
+  created (aching).
  
   GIRAPH-40: Added checkstyle for enforcement of code conventions.
   All Giraph source files now pass checkstyle. (aching)

Modified: incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
URL: http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java?rev=1291382&r1=1291381&r2=1291382&view=diff
==============================================================================
--- incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java (original)
+++ incubator/giraph/trunk/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java Mon Feb 20 17:26:11 2012
@@ -124,7 +124,8 @@ public class PageRankBenchmark extends E
     } else {
       job.setVertexClass(PageRankBenchmark.class);
     }
-    LOG.info("Using class " + BspUtils.getVertexClass(getConf()).getName());
+    LOG.info("Using class " +
+        BspUtils.getVertexClass(job.getConfiguration()).getName());
     job.setVertexInputFormatClass(PseudoRandomVertexInputFormat.class);
     job.setWorkerConfiguration(workers, workers, 100.0f);
     job.getConfiguration().setLong(
@@ -142,8 +143,9 @@ public class PageRankBenchmark extends E
       isVerbose = true;
     }
     if (cmd.hasOption('s')) {
-      getConf().setInt(PageRankComputation.SUPERSTEP_COUNT,
-                       Integer.parseInt(cmd.getOptionValue('s')));
+      job.getConfiguration().setInt(
+          PageRankComputation.SUPERSTEP_COUNT,
+          Integer.parseInt(cmd.getOptionValue('s')));
     }
     if (job.run(isVerbose)) {
       return 0;