You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by pr...@apache.org on 2010/02/03 07:08:13 UTC
svn commit: r905906 -
/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Author: pradeepkth
Date: Wed Feb 3 06:08:12 2010
New Revision: 905906
URL: http://svn.apache.org/viewvc?rev=905906&view=rev
Log:
minor fix in the code calling storeSchema in pigOuputCommitter
Modified:
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Modified: hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java?rev=905906&r1=905905&r2=905906&view=diff
==============================================================================
--- hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java (original)
+++ hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java Wed Feb 3 06:08:12 2010
@@ -175,14 +175,14 @@
for (Pair<OutputCommitter, POStore> mapCommitter : mapOutputCommitters) {
JobContext updatedContext = setUpContext(context,
mapCommitter.second);
- storeCleanup(mapCommitter.second, context.getConfiguration());
+ storeCleanup(mapCommitter.second, updatedContext.getConfiguration());
mapCommitter.first.cleanupJob(updatedContext);
}
for (Pair<OutputCommitter, POStore> reduceCommitter :
reduceOutputCommitters) {
JobContext updatedContext = setUpContext(context,
reduceCommitter.second);
- storeCleanup(reduceCommitter.second, context.getConfiguration());
+ storeCleanup(reduceCommitter.second, updatedContext.getConfiguration());
reduceCommitter.first.cleanupJob(updatedContext);
}