apache/kyuubi
1
0
Fork 0
Code Issues Pull Requests Actions 5 Packages Projects Releases Wiki Activity

fix#158 do not delete session resouces dir in close session (#159)

Browse Source
This commit is contained in:
Kent Yao 2019-03-05 20:14:13 +08:00 committed by GitHub
parent 7401ca3c6e
commit 7631ac3a8b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
kyuubi-server/src/main/scala/yaooqinn/kyuubi/session/KyuubiSession.scala
View File

@ -137,15 +137,6 @@ private[kyuubi] class KyuubiSession(
}
}
private def cleanupSessionResourcesDir(): Unit = {
try {
FileUtils.forceDelete(sessionResourcesDir)
} catch {
case e: Exception =>
error("Failed to cleanup session log dir: " + sessionResourcesDir, e)
}
}
def sparkSession: SparkSession = this.sparkSessionWithUGI.sparkSession
def ugi: UserGroupInformation = this.sessionUGI
@ -205,8 +196,6 @@ private[kyuubi] class KyuubiSession(
// Iterate through the opHandles and close their operations
opHandleSet.foreach(closeOperation)
opHandleSet.clear()
// Cleanup session resources directory
cleanupSessionResourcesDir()
// Cleanup session log directory.
cleanupSessionLogDir()
} finally {