pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pradeep...@apache.org
Subject svn commit: r905906 - /hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Date Wed, 03 Feb 2010 06:08:13 GMT
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);
         }
        



Mime
View raw message