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;