tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gop...@apache.org
Subject git commit: TEZ-638. Bring pipelined sorter up-to-date. (gopalv)
Date Wed, 04 Dec 2013 10:14:47 GMT
Updated Branches:
  refs/heads/master 7e3f4c2cd -> af170946e


TEZ-638. Bring pipelined sorter up-to-date. (gopalv)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/af170946
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/af170946
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/af170946

Branch: refs/heads/master
Commit: af170946ed45934dc3c02987e21fb5425396752e
Parents: 7e3f4c2
Author: Gopal V <gopalv@apache.org>
Authored: Wed Dec 4 15:32:16 2013 +0530
Committer: Gopal V <gopalv@apache.org>
Committed: Wed Dec 4 15:32:16 2013 +0530

----------------------------------------------------------------------
 .../tez/runtime/library/common/sort/impl/PipelinedSorter.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/af170946/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java
----------------------------------------------------------------------
diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java
b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java
index 1c6ee5d..f556e22 100644
--- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java
+++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/PipelinedSorter.java
@@ -328,8 +328,8 @@ public class PipelinedSorter extends ExternalSorter {
           mapOutputFile.getSpillFile(0);
       Path indexFilename =
               mapOutputFile.getSpillIndexFile(0);
-      sameVolRename(filename, finalOutputFile);
-      sameVolRename(indexFilename, finalIndexFile);
+      sameVolRename(filename, mapOutputFile.getOutputFileForWriteInVolume(filename));
+      sameVolRename(indexFilename, mapOutputFile.getOutputIndexFileForWriteInVolume(indexFilename));
       return;
     }
     


Mime
View raw message