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); }