hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jo...@apache.org
Subject svn commit: r713415 - in /hadoop/core/trunk: CHANGES.txt src/mapred/org/apache/hadoop/mapred/pipes/Application.java
Date Wed, 12 Nov 2008 16:05:40 GMT
Author: johan
Date: Wed Nov 12 08:05:40 2008
New Revision: 713415

URL: http://svn.apache.org/viewvc?rev=713415&view=rev
Log:
HADOOP-4622. Explicitly specify interpretor for non-native pipes binaries. (Fredrik Hedberg
via johan) 

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/pipes/Application.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=713415&r1=713414&r2=713415&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Wed Nov 12 08:05:40 2008
@@ -89,6 +89,9 @@
     szetszwo)
 
     HADOOP-3923. Remove org.apache.hadoop.mapred.StatusHttpServer.  (szetszwo)
+    
+    HADOOP-4622. Explicitly specify interpretor for non-native
+    pipes binaries. (Fredrik Hedberg via johan)    
 
   OPTIMIZATIONS
 

Modified: hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/pipes/Application.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/pipes/Application.java?rev=713415&r1=713414&r2=713415&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/pipes/Application.java (original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/pipes/Application.java Wed Nov 12
08:05:40 2008
@@ -83,6 +83,11 @@
     env.put("hadoop.pipes.command.port", 
             Integer.toString(serverSocket.getLocalPort()));
     List<String> cmd = new ArrayList<String>();
+    String interpretor = conf.get("hadoop.pipes.executable.interpretor");
+    if (interpretor != null) {
+      cmd.add(interpretor);
+    }
+
     String executable = DistributedCache.getLocalCacheFiles(conf)[0].toString();
     FileUtil.chmod(executable, "a+x");
     cmd.add(executable);



Mime
View raw message