File tree Expand file tree Collapse file tree
sql/hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -150,10 +150,14 @@ private[sql] class HiveSessionCatalog(
150150 case ArchiveResource =>
151151 ResourceType .ARCHIVE
152152 }
153- val sessionState = SessionState .get()
154- val localPath = sessionState.add_resource(resourceType, resource.uri)
155- ShutdownHookManager .registerShutdownDeleteDir(new File (localPath).getParentFile)
156- functionResourceLoader.loadResource(FunctionResource (resource.resourceType, localPath))
153+ if (System .getProperties(" spark.testing" ) != " true" ) {
154+ val sessionState = SessionState .get()
155+ val localPath = sessionState.add_resource(resourceType, resource.uri)
156+ ShutdownHookManager .registerShutdownDeleteDir(new File (localPath).getParentFile)
157+ functionResourceLoader.loadResource(FunctionResource (resource.resourceType, localPath))
158+ } else {
159+ functionResourceLoader.loadResource(resource)
160+ }
157161 }
158162 }
159163
You can’t perform that action at this time.
0 commit comments