  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 @@ class Application<K1 extends WritableComparable, V1 extends Writable,
+@@ -95,14 +96,21 @@
      env.put("hadoop.pipes.command.port", 
              Integer.toString(serverSocket.getLocalPort()));
      

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

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