|
@@ -328,6 +328,7 @@ public class HadoopArchives implements Tool {
|
|
try {
|
|
try {
|
|
// write the top level dirs in first
|
|
// write the top level dirs in first
|
|
writeTopLevelDirs(srcWriter, srcPaths);
|
|
writeTopLevelDirs(srcWriter, srcPaths);
|
|
|
|
+ srcWriter.sync();
|
|
// these are the input paths passed
|
|
// these are the input paths passed
|
|
// from the command line
|
|
// from the command line
|
|
// we do a recursive ls on these paths
|
|
// we do a recursive ls on these paths
|
|
@@ -356,6 +357,7 @@ public class HadoopArchives implements Tool {
|
|
}
|
|
}
|
|
srcWriter.append(new LongWritable(len), new
|
|
srcWriter.append(new LongWritable(len), new
|
|
Text(toWrite));
|
|
Text(toWrite));
|
|
|
|
+ srcWriter.sync();
|
|
numFiles++;
|
|
numFiles++;
|
|
totalSize += len;
|
|
totalSize += len;
|
|
}
|
|
}
|