svn commit: r884587 - /lucene/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java

[ab]

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;