Index: src/java/org/apache/nutch/fetcher/FetcherOutputFormat.java
===================================================================
--- src/java/org/apache/nutch/fetcher/FetcherOutputFormat.java	(revision 417577)
+++ src/java/org/apache/nutch/fetcher/FetcherOutputFormat.java	(working copy)
@@ -31,6 +31,7 @@
 import org.apache.hadoop.mapred.RecordWriter;
 import org.apache.hadoop.mapred.JobConf;
 import org.apache.hadoop.mapred.Reporter;
+import org.apache.hadoop.util.Progressable;
 
 import org.apache.nutch.parse.ParseOutputFormat;
 import org.apache.nutch.protocol.Content;
@@ -45,6 +46,13 @@
 
   public RecordWriter getRecordWriter(final FileSystem fs,
                                       final JobConf job,
+                                      final String name,
+                                      final Progressable progress) throws IOException {
+      return getRecordWriter(fs, job, name);
+  }
+  
+  public RecordWriter getRecordWriter(final FileSystem fs,
+                                      final JobConf job,
                                       final String name) throws IOException {
 
     final Path fetch =
Index: src/java/org/apache/nutch/indexer/DeleteDuplicates.java
===================================================================
--- src/java/org/apache/nutch/indexer/DeleteDuplicates.java	(revision 417577)
+++ src/java/org/apache/nutch/indexer/DeleteDuplicates.java	(working copy)
@@ -26,6 +26,7 @@
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.conf.*;
 import org.apache.hadoop.mapred.*;
+import org.apache.hadoop.util.Progressable;
 
 import org.apache.nutch.util.NutchConfiguration;
 import org.apache.nutch.util.NutchJob;
@@ -273,6 +274,13 @@
     }
   }
 
+  public RecordWriter getRecordWriter(final FileSystem fs,
+                                      final JobConf job,
+                                      final String name,
+                                      final Progressable progress) throws IOException {
+      return getRecordWriter(fs, job, name);
+  }
+  
   /** Write nothing. */
   public RecordWriter getRecordWriter(final FileSystem fs,
                                       final JobConf job,
Index: src/java/org/apache/nutch/indexer/Indexer.java
===================================================================
--- src/java/org/apache/nutch/indexer/Indexer.java	(revision 417577)
+++ src/java/org/apache/nutch/indexer/Indexer.java	(working copy)
@@ -27,6 +27,7 @@
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.conf.*;
 import org.apache.hadoop.mapred.*;
+import org.apache.hadoop.util.Progressable;
 import org.apache.nutch.parse.*;
 import org.apache.nutch.analysis.*;
 
@@ -79,6 +80,12 @@
   public static class OutputFormat
     extends org.apache.hadoop.mapred.OutputFormatBase {
     public RecordWriter getRecordWriter(final FileSystem fs, JobConf job,
+                                        String name, Progressable progress)
+                                        throws IOException {
+        return getRecordWriter(fs, job, name);
+    }
+    
+    public RecordWriter getRecordWriter(final FileSystem fs, JobConf job,
                                         String name) throws IOException {
       final Path perm = new Path(job.getOutputPath(), name);
       final Path temp =
Index: src/java/org/apache/nutch/segment/SegmentMerger.java
===================================================================
--- src/java/org/apache/nutch/segment/SegmentMerger.java	(revision 417577)
+++ src/java/org/apache/nutch/segment/SegmentMerger.java	(working copy)
@@ -28,6 +28,7 @@
 import org.apache.hadoop.fs.PathFilter;
 import org.apache.hadoop.io.*;
 import org.apache.hadoop.mapred.*;
+import org.apache.hadoop.util.Progressable;
 import org.apache.nutch.crawl.CrawlDatum;
 import org.apache.nutch.crawl.Generator;
 import org.apache.nutch.fetcher.Fetcher;
@@ -168,6 +169,11 @@
   public static class SegmentOutputFormat extends org.apache.hadoop.mapred.OutputFormatBase {
     private static final String DEFAULT_SLICE = "default";
     
+    public RecordWriter getRecordWriter(final FileSystem fs, final JobConf job,
+            final String name, final Progressable progress) throws IOException {
+        return getRecordWriter(fs, job, name);
+    }
+    
     public RecordWriter getRecordWriter(final FileSystem fs, final JobConf job, final String name) throws IOException {
       return new RecordWriter() {
         MapFile.Writer c_out = null;
Index: src/java/org/apache/nutch/segment/SegmentReader.java
===================================================================
--- src/java/org/apache/nutch/segment/SegmentReader.java	(revision 417577)
+++ src/java/org/apache/nutch/segment/SegmentReader.java	(working copy)
@@ -28,6 +28,7 @@
 import org.apache.hadoop.fs.*;
 import org.apache.hadoop.io.*;
 import org.apache.hadoop.mapred.*;
+import org.apache.hadoop.util.Progressable;
 import org.apache.nutch.crawl.CrawlDatum;
 import org.apache.nutch.parse.ParseData;
 import org.apache.nutch.parse.ParseText;
@@ -70,6 +71,11 @@
 
   /** Implements a text output format */
   public static class TextOutputFormat extends org.apache.hadoop.mapred.OutputFormatBase {
+    public RecordWriter getRecordWriter(final FileSystem fs, JobConf job,
+            String name, Progressable progress) throws IOException {
+        return getRecordWriter(fs, job, name);
+    }
+    
     public RecordWriter getRecordWriter(final FileSystem fs, JobConf job, String name) throws IOException {
 
       final Path segmentDumpFile = new Path(job.getOutputPath(), name);
Index: src/java/org/apache/nutch/parse/ParseOutputFormat.java
===================================================================
--- src/java/org/apache/nutch/parse/ParseOutputFormat.java	(revision 417577)
+++ src/java/org/apache/nutch/parse/ParseOutputFormat.java	(working copy)
@@ -31,6 +31,7 @@
 import org.apache.nutch.net.*;
 
 import java.io.*;
+import org.apache.hadoop.util.Progressable;
 
 /* Parse content in a segment. */
 public class ParseOutputFormat implements OutputFormat {
@@ -46,6 +47,12 @@
   }
 
   public RecordWriter getRecordWriter(FileSystem fs, JobConf job,
+                                      String name, Progressable progress)
+                                      throws IOException {
+      return getRecordWriter(fs, job, name);
+  }
+  
+  public RecordWriter getRecordWriter(FileSystem fs, JobConf job,
                                       String name) throws IOException {
 
     this.urlNormalizer = new UrlNormalizerFactory(job).getNormalizer();