You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ol...@apache.org on 2008/06/17 20:47:52 UTC
svn commit: r668790 - in /incubator/pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
Author: olga
Date: Tue Jun 17 11:47:52 2008
New Revision: 668790
URL: http://svn.apache.org/viewvc?rev=668790&view=rev
Log:
PIG-266: fixed warnings caused by HOD
Modified:
incubator/pig/trunk/CHANGES.txt
incubator/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
Modified: incubator/pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/pig/trunk/CHANGES.txt?rev=668790&r1=668789&r2=668790&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Tue Jun 17 11:47:52 2008
@@ -316,3 +316,5 @@
PIG-198: Fixed pig script to pick up hadoop 17 instead of 15 (pi_song via gates).
PIG-256: Added variable argument support for UDFs (pi_song)
+
+ PIG-266: fix warnings caused by HOD
Modified: incubator/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
URL: http://svn.apache.org/viewvc/incubator/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java?rev=668790&r1=668789&r2=668790&view=diff
==============================================================================
--- incubator/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java (original)
+++ incubator/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java Tue Jun 17 11:47:52 2008
@@ -415,8 +415,10 @@
throw new ExecException("Missing mapred.job.tracker from hadoop configuration");
log.info("JobTracker: " + mapred);
- hdfs = fixUpDomain(hdfs, properties);
- mapred = fixUpDomain(mapred, properties);
+ // this is not longer needed as hadoop-site.xml given to us by HOD
+ // contains data in the correct format
+ // hdfs = fixUpDomain(hdfs, properties);
+ // mapred = fixUpDomain(mapred, properties);
hodHDFS = hdfs;
hodMapRed = mapred;