commit 26f6a6644b830b65d4899f6a7dba63c6fc4ac307

Author: Lee Tucker <ltucker@yahoo-inc.com>
Date:   Thu Jul 30 17:40:31 2009 -0700

    Applying patch 2793428.5980.patch


git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.20-security-patches@1076947 13f79535-47bb-0310-9956-ffa450edef68

src/mapred/org/apache/hadoop/mapred/LinuxTaskController.java

@@ -24,6 +24,8 @@ import java.io.IOException;
 import java.io.PrintWriter;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Set;
+import java.util.Map.Entry;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -125,10 +127,19 @@ class LinuxTaskController extends TaskController {
     String cmdLine = 
       TaskLog.buildCommandLine(env.setup, env.vargs, env.stdout, env.stderr,
           env.logSize, env.pidFile);
+    StringBuffer sb = new StringBuffer();
+    //export out all the environment variable before child command.
+    for(Entry<String, String> entry : env.env.entrySet()) {
+      sb.append("export ");
+      sb.append(entry.getKey());
+      sb.append("=");
+      sb.append(entry.getValue());
+      sb.append("\n");
+    }
+    sb.append(cmdLine);
     // write the command to a file in the
     // task specific cache directory
-    writeCommand(cmdLine, getTaskCacheDirectory(context));
-    
+    writeCommand(sb.toString(), getTaskCacheDirectory(context));
     // Call the taskcontroller with the right parameters.
     List<String> launchTaskJVMArgs = buildTaskCommandArgs(context);
     ShellCommandExecutor shExec =  buildTaskControllerExecutor(