You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by ab...@apache.org on 2007/02/15 18:00:18 UTC
svn commit: r508011 -
/lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java
Author: ab
Date: Thu Feb 15 09:00:17 2007
New Revision: 508011
URL: http://svn.apache.org/viewvc?view=rev&rev=508011
Log:
IndexReducer was applied to the wrong job. Spotted by Dennis Kubes.
Modified:
lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java
Modified: lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java
URL: http://svn.apache.org/viewvc/lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java?view=diff&rev=508011&r1=508010&r2=508011
==============================================================================
--- lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java (original)
+++ lucene/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java Thu Feb 15 09:00:17 2007
@@ -150,7 +150,6 @@
sortJob.setJobName("inject " + urlDir);
sortJob.setInputPath(urlDir);
sortJob.setMapperClass(InjectMapper.class);
- sortJob.setReducerClass(InjectReducer.class);
sortJob.setOutputPath(tempDir);
sortJob.setOutputFormat(SequenceFileOutputFormat.class);
@@ -164,6 +163,7 @@
}
JobConf mergeJob = CrawlDb.createJob(getConf(), crawlDb);
mergeJob.addInputPath(tempDir);
+ mergeJob.setReducerClass(InjectReducer.class);
JobClient.runJob(mergeJob);
CrawlDb.install(mergeJob, crawlDb);