svn commit: r898901 - /hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java

[pradeepkth]

Author: pradeepkth
Date: Wed Jan 13 19:20:02 2010
New Revision: 898901

URL: http://svn.apache.org/viewvc?rev=898901&view=rev
Log:
minor fix to pass real InputSplit in createRecordReader call in PigInputFormat

Modified:
    
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java

Modified: 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java?rev=898901&r1=898900&r2=898901&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
 Wed Jan 13 19:20:02 2010
@@ -95,7 +95,8 @@
         PigInputFormat.mergeSplitSpecificConf(loadFunc, pigSplit, conf);
         InputFormat inputFormat = loadFunc.getInputFormat();
         // now invoke the createRecordReader() with this "adjusted" conf
-        RecordReader reader = inputFormat.createRecordReader(split, context);
+        RecordReader reader = inputFormat.createRecordReader(
+                pigSplit.getWrappedSplit(), context);
         
         return new PigRecordReader(reader, loadFunc, conf);
     }