Github user jiangxb1987 commented on a diff in the pull request: https://github.com/apache/spark/pull/20812#discussion_r174699183 --- Diff: core/src/main/scala/org/apache/spark/executor/Executor.scala --- @@ -752,11 +752,10 @@ private[spark] class Executor( if (currentTimeStamp < timestamp) { logInfo("Fetching " + name + " with timestamp " + timestamp) // Fetch file with useCache mode, close cache for local mode. - Utils.fetchFile(name, new File(SparkFiles.getRootDirectory()), conf, - env.securityManager, hadoopConf, timestamp, useCache = !isLocal) + val url = Utils.fetchFile(name, new File(SparkFiles.getRootDirectory()), conf, + env.securityManager, hadoopConf, timestamp, useCache = !isLocal, + conf.getBoolean("spark.jars.withDecoratedName", false)).toURI.toURL currentJars(name) = timestamp - // Add it to our class loader - val url = new File(SparkFiles.getRootDirectory(), localName).toURI.toURL --- End diff -- shall we still need the `localName` here?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org