diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index b7d40c6..ac4b5a1 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -850,7 +850,7 @@ public LocalResource localizeResource(Path src, Path dest, Configuration conf) throws IOException { FileSystem destFS = dest.getFileSystem(conf); - if (src != null) { + if (src != null && checkPreExisting(src, dest, conf) == false) { // copy the src to the destination and create local resource. // do not overwrite. LOG.info("Localizing resource because it does not exist: " + src + " to dest: " + dest);