Author: bobby Date: Wed Aug 15 19:51:16 2012 New Revision: 1373600 URL: http://svn.apache.org/viewvc?rev=1373600&view=rev Log: svn emrge -c 1373599. FIXES: HADOOP-8703
Modified: hadoop/common/branches/branch-2/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java Modified: hadoop/common/branches/branch-2/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java?rev=1373600&r1=1373599&r2=1373600&view=diff ============================================================================== --- hadoop/common/branches/branch-2/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java (original) +++ hadoop/common/branches/branch-2/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java Wed Aug 15 19:51:16 2012 @@ -92,8 +92,9 @@ public class RetriableFileCopyCommand ex compareFileLengths(sourceFileStatus, tmpTargetPath, configuration, bytesRead); //At this point, src&dest lengths are same. if length==0, we skip checksum - if (bytesRead != 0) - compareCheckSums(sourceFS, sourceFileStatus.getPath(), targetFS, tmpTargetPath); + if (bytesRead != 0) { + compareCheckSums(sourceFS, sourceFileStatus.getPath(), targetFS, tmpTargetPath); + } promoteTmpToTarget(tmpTargetPath, target, targetFS); return bytesRead;