diff --git a/src/java/org/apache/nutch/fetcher/Fetcher.java b/src/java/org/apache/nutch/fetcher/Fetcher.java index acf8a5728f..3877071186 100644 --- a/src/java/org/apache/nutch/fetcher/Fetcher.java +++ b/src/java/org/apache/nutch/fetcher/Fetcher.java @@ -631,7 +631,6 @@ public void fetch(Path segment, int threads) throws IOException, job.setJarByClass(Fetcher.class); job.setMapperClass(Fetcher.FetcherRun.class); job.setReducerClass(Fetcher.FetcherReducer.class); - job.setNumReduceTasks(1); FileOutputFormat.setOutputPath(job, segment); job.setOutputFormatClass(FetcherOutputFormat.class);