diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala index cd12dbd36c4..410f141e0b8 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilder.scala @@ -190,6 +190,7 @@ object SparkProcessBuilder { final val APP_KEY = "spark.app.name" final val TAG_KEY = "spark.yarn.tags" final val MASTER_KEY = "spark.master" + final val INTERNAL_RESOURCE = "spark-internal" /** * The path configs from Spark project that might upload local files: diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala index 24dcc0477c3..5a17915cbcb 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala @@ -27,6 +27,7 @@ import org.apache.hive.service.rpc.thrift.TProtocolVersion import org.apache.kyuubi.client.api.v1.dto.BatchRequest import org.apache.kyuubi.config.KyuubiConf import org.apache.kyuubi.engine.KyuubiApplicationManager +import org.apache.kyuubi.engine.spark.SparkProcessBuilder import org.apache.kyuubi.events.{EventBus, KyuubiSessionEvent} import org.apache.kyuubi.metrics.MetricsConstants.{CONN_OPEN, CONN_TOTAL} import org.apache.kyuubi.metrics.MetricsSystem @@ -99,9 +100,11 @@ class KyuubiBatchSessionImpl( batchRequest.getBatchType, normalizedConf, sessionManager.getConf) - KyuubiApplicationManager.checkApplicationAccessPath( - batchRequest.getResource, - sessionManager.getConf) + if (batchRequest.getResource != SparkProcessBuilder.INTERNAL_RESOURCE) { + KyuubiApplicationManager.checkApplicationAccessPath( + batchRequest.getResource, + sessionManager.getConf) + } } override def open(): Unit = {