@@ -318,7 +318,7 @@ private[spark] object Utils extends Logging {
318318 *
319319 * If `useCache` is true, first attempts to fetch the file to a local cache that's shared
320320 * across executors running the same application. `useCache` is used mainly for
321- * the the executors, not in local mode.
321+ * the executors, and not in local mode.
322322 *
323323 * Throws SparkException if the target file already exists and has different contents than
324324 * the requested file.
@@ -341,7 +341,7 @@ private[spark] object Utils extends Logging {
341341 val raf = new RandomAccessFile (lockFile, " rw" )
342342 // Only one executor entry.
343343 // The FileLock is only used to control synchronization for executors download file,
344- // it's always safe regardless of lock type(mandatory or advisory).
344+ // it's always safe regardless of lock type (mandatory or advisory).
345345 val lock = raf.getChannel().lock()
346346 val cachedFile = new File (localDir, cachedFileName)
347347 try {
@@ -354,8 +354,8 @@ private[spark] object Utils extends Logging {
354354 if (targetFile.exists && ! Files .equal(cachedFile, targetFile)) {
355355 if (conf.getBoolean(" spark.files.overwrite" , false )) {
356356 targetFile.delete()
357- logInfo((" File %s exists and does not match contents of %s , " +
358- " replacing it with %s " ).format(targetFile, url, url ))
357+ logInfo((s " File $targetFile exists and does not match contents of $url , " +
358+ s " replacing it with $ url" ))
359359 } else {
360360 throw new SparkException (s " File $targetFile exists and does not match contents of $url" )
361361 }
0 commit comments