diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/KyuubiApplicationManager.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/KyuubiApplicationManager.scala index f8b640053..a34b0f66a 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/KyuubiApplicationManager.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/KyuubiApplicationManager.scala @@ -123,8 +123,9 @@ object KyuubiApplicationManager { } private[kyuubi] def checkApplicationAccessPath(path: String, conf: KyuubiConf): Unit = { - val localDirAllowList = conf.get(KyuubiConf.SESSION_LOCAL_DIR_ALLOW_LIST) + var localDirAllowList: Set[String] = conf.get(KyuubiConf.SESSION_LOCAL_DIR_ALLOW_LIST) if (localDirAllowList.nonEmpty) { + localDirAllowList ++= Set(uploadWorkDir.toUri.getPath) val uri = try { new URI(path) diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala index 612a546e1..0ba7c0c8d 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala @@ -145,7 +145,7 @@ class KyuubiBatchSession( batchType, optimizedConf, sessionManager.getConf) - if (resource != SparkProcessBuilder.INTERNAL_RESOURCE && !isResourceUploaded) { + if (resource != SparkProcessBuilder.INTERNAL_RESOURCE) { KyuubiApplicationManager.checkApplicationAccessPath(resource, sessionManager.getConf) } }