Skip to content

Commit

Permalink
[CORE] Fix the java.nio.file.NoSuchFileException: default in spark 3.5 (
Browse files Browse the repository at this point in the history
  • Loading branch information
ulysses-you authored Jun 24, 2024
1 parent 4ed161b commit 9cceba6
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,8 +41,8 @@ object HdfsConfGenerator extends Logging {
addFileMethod.invoke(sc, path, Boolean.box(false), Boolean.box(true), Boolean.box(false))
// Overwrite the spark internal config `spark.app.initial.file.urls`,
// so that the file can be available before initializing executor plugin.
assert(sc.addedFiles.nonEmpty)
sc.conf.set("spark.app.initial.file.urls", sc.addedFiles.keys.toSeq.mkString(","))
assert(sc.listFiles.nonEmpty)
sc.conf.set("spark.app.initial.file.urls", sc.listFiles().mkString(","))
}

private def ignoreKey(key: String): Boolean = {
Expand Down

0 comments on commit 9cceba6

Please sign in to comment.