diff --git a/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java b/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java index fa9193077ac..52834b974e7 100644 --- a/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java +++ b/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/RetriableFileCopyCommand.java @@ -229,7 +229,8 @@ private Path getTempFile(Path target, Mapper.Context context) { Path root = target.equals(targetWorkPath) ? targetWorkPath.getParent() : targetWorkPath; Path tempFile = new Path(root, ".distcp.tmp." + - context.getTaskAttemptID().toString()); + context.getTaskAttemptID().toString() + + "." + String.valueOf(System.currentTimeMillis())); LOG.info("Creating temp file: {}", tempFile); return tempFile; }