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;