Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20812#discussion_r174699762
--- 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
--- End diff --
should we have this conf in `internal/conf` ?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
