Fix copy that was changed to a move inadvertently

markhamstra · Dec 16, 2014 · c14daff · c14daff
1 parent 8e39c16
commit c14daff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -548,7 +548,7 @@ private[spark] object Utils extends Logging {
         // In the case of a local file, copy the local file to the target directory.
         // Note the difference between uri vs url.
         val sourceFile = if (uri.isAbsolute) new File(uri) else new File(url)
-        copyFile(url, sourceFile, targetFile, fileOverwrite, removeSourceFile = true)
+        copyFile(url, sourceFile, targetFile, fileOverwrite)
       case _ =>
         // Use the Hadoop filesystem library, which supports file://, hdfs://, s3://, and others
         val fs = getHadoopFileSystem(uri, hadoopConf)