svn commit: r668790 - in /incubator/pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java

[olga]

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;