|
@@ -145,7 +145,7 @@ public class RetriableFileCopyCommand extends RetriableCommand {
|
|
if (!source.isSplit()) {
|
|
if (!source.isSplit()) {
|
|
DistCpUtils.compareFileLengthsAndChecksums(source.getLen(), sourceFS,
|
|
DistCpUtils.compareFileLengthsAndChecksums(source.getLen(), sourceFS,
|
|
sourcePath, sourceChecksum, targetFS,
|
|
sourcePath, sourceChecksum, targetFS,
|
|
- targetPath, skipCrc, source.getLen());
|
|
|
|
|
|
+ targetPath, skipCrc, offset + bytesRead);
|
|
}
|
|
}
|
|
// it's not append or direct write (preferred for s3a) case, thus we first
|
|
// it's not append or direct write (preferred for s3a) case, thus we first
|
|
// write to a temporary file, then rename it to the target path.
|
|
// write to a temporary file, then rename it to the target path.
|