pradeepkth
Tue, 03 Nov 2009 18:13:35 -0800
Author: pradeepkth Date: Tue Nov 3 23:07:35 2009 New Revision: 832594 URL: http://svn.apache.org/viewvc?rev=832594&view=rev Log: corrected a bug with not using a copy of JobContext in checkOutputSpecs()
Modified:
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputFormat.java
Modified:
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputFormat.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputFormat.java?rev=832594&r1=832593&r2=832594&view=diff
==============================================================================
---
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputFormat.java
(original)
+++
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputFormat.java
Tue Nov 3 23:07:35 2009
@@ -209,11 +209,11 @@
jobcontext.getConfiguration(), jobcontext.getJobID());
// set output location
- PigOutputFormat.setLocation(jobcontext, sFunc,
+ PigOutputFormat.setLocation(jobContextCopy, sFunc,
store.getSFile().getFileName());
// The above call should have update the conf in the JobContext
// to have the output location - now call checkOutputSpecs()
- of.checkOutputSpecs(jobcontext);
+ of.checkOutputSpecs(jobContextCopy);
}
}
/**