  #include "hdfsJniHelper.h"
  
  static pthread_mutex_t hdfsHashMutex = PTHREAD_MUTEX_INITIALIZER;
-diff -urN src/hadoop-1.0.4/org/apache/hadoop/mapred/pipes/Application.java src/hadoop-1.0.4.patched/org/apache/hadoop/mapred/pipes/Application.java
---- src/hadoop-1.0.4/org/apache/hadoop/mapred/pipes/Application.java	2012-12-03 19:17:41.471432541 +0100
-+++ src/hadoop-1.0.4.patched/org/apache/hadoop/mapred/pipes/Application.java	2013-02-13 23:15:48.683751644 +0100
-@@ -48,6 +48,7 @@
+diff --git a/org/apache/hadoop/mapred/pipes/Application.java b/org/apache/hadoop/mapred/pipes/Application.java
+index 9d41dc3..f3e405d 100644
+--- a/org/apache/hadoop/mapred/pipes/Application.java
++++ b/org/apache/hadoop/mapred/pipes/Application.java
+@@ -48,6 +48,7 @@ import org.apache.hadoop.mapred.RecordReader;
  import org.apache.hadoop.mapred.Reporter;
  import org.apache.hadoop.mapred.TaskAttemptID;
  import org.apache.hadoop.mapred.TaskLog;

 #include <sys/socket.h>
 #include <pthread.h>
 #include <iostream>
@@ -126,7 +127,7 @@
     static const char lineSeparator = '\n';
 
     void writeBuffer(const string& buffer) {

     }
 
   public:
@@ -802,14 +803,20 @@ namespace HadoopPipes {
       if (numReduces != 0) { 
         reducer = factory->createCombiner(*this);
         partitioner = factory->createPartitioner(*this);
-      }
-      if (reducer != NULL) {
-        int64_t spillSize = 100;
-        if (jobConf->hasKey("io.sort.mb")) {
-          spillSize = jobConf->getInt("io.sort.mb");
-        }
-        writer = new CombineRunner(spillSize * 1024 * 1024, this, reducer, 
-                                   uplink, partitioner, numReduces);
+	if (reducer != NULL) {
+	  int64_t spillSize = 100;
+	  if (jobConf->hasKey("io.sort.mb")) {
