  import org.apache.hadoop.mapreduce.security.SecureShuffleUtils;
  import org.apache.hadoop.mapreduce.security.TokenCache;
  import org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier;
-@@ -95,14 +96,21 @@
+@@ -95,14 +96,21 @@ class Application<K1 extends WritableComparable, V1 extends Writable,
      env.put("hadoop.pipes.command.port", 
              Integer.toString(serverSocket.getLocalPort()));
      

 #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 @@
 import org.apache.hadoop.mapred.Reporter;
 import org.apache.hadoop.mapred.TaskAttemptID;
 import org.apache.hadoop.mapred.TaskLog;

     writePasswordToLocalFile(localPasswordFile, password, conf);
     env.put("hadoop.pipes.shared.secret.location", localPasswordFile);
  
@@ -120,7 +128,6 @@ class Application<K1 extends WritableComparable, V1 extends Writable,
     }
     cmd.add(executable);
     // wrap the command in a stdout/stderr capture
