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


Reply via email to