You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by jo...@apache.org on 2008/11/12 17:05:40 UTC
svn commit: r713415 - in /hadoop/core/trunk: CHANGES.txt
src/mapred/org/apache/hadoop/mapred/pipes/Application.java
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);