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