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 2009/11/26 16:35:57 UTC
svn commit: r884587 -
/lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java
Author: ab
Date: Thu Nov 26 15:35:56 2009
New Revision: 884587
URL: http://svn.apache.org/viewvc?rev=884587&view=rev
Log:
Fix a bug resulting from over-eager optimization in NUTCH-761.
Modified:
lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java
Modified: lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java
URL: http://svn.apache.org/viewvc/lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java?rev=884587&r1=884586&r2=884587&view=diff
==============================================================================
--- lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java (original)
+++ lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java Thu Nov 26 15:35:56 2009
@@ -42,8 +42,6 @@
private boolean additionsAllowed;
private int maxInterval;
private FetchSchedule schedule;
- private CrawlDatum fetch = new CrawlDatum();
- private CrawlDatum old = new CrawlDatum();
public void configure(JobConf job) {
retryMax = job.getInt("db.fetch.retry.max", 3);
@@ -61,6 +59,9 @@
OutputCollector<Text, CrawlDatum> output, Reporter reporter)
throws IOException {
+ CrawlDatum fetch = new CrawlDatum();
+ CrawlDatum old = new CrawlDatum();
+
boolean fetchSet = false;
boolean oldSet = false;
byte[] signature = null;