      }
  
    public:
-@@ -803,14 +803,20 @@ namespace HadoopPipes {
+@@ -803,14 +810,20 @@ namespace HadoopPipes {
        if (numReduces != 0) { 
          reducer = factory->createCombiner(*this);
          partitioner = factory->createPartitioner(*this);

       }
       hasTask = true;
     }
diff --git a/utils/impl/SerialUtils.cc b/utils/impl/SerialUtils.cc
index 03d009b..3736373 100644
--- a/utils/impl/SerialUtils.cc

     File stderr = TaskLog.getTaskLogFile(taskid, false, TaskLog.LogName.STDERR);
     long logLength = TaskLog.getTaskLogLength(conf);
diff --git a/pipes/impl/HadoopPipes.cc b/pipes/impl/HadoopPipes.cc
index 1d2fc95..fdb50c2 100644
--- a/pipes/impl/HadoopPipes.cc
+++ b/pipes/impl/HadoopPipes.cc
@@ -83,6 +83,13 @@ namespace HadoopPipes {
     }
   };
 
+char* _get_command_port(){
+	char* mapreduce_command_port = getenv("mapreduce.pipes.command.port");
+  if(mapreduce_command_port != NULL)
+    return mapreduce_command_port;
+  return getenv("hadoop.pipes.command.port");
+  }
+
   class DownwardProtocol {
   public:
     virtual void start(int protocol) = 0;
@@ -127,7 +134,7 @@ namespace HadoopPipes {
     static const char lineSeparator = '\n';
 
     void writeBuffer(const string& buffer) {
