From 7631ac3a8bb7942337ded74de48fc4472fd7c9f4 Mon Sep 17 00:00:00 2001 From: Kent Yao <11215016@zju.edu.cn> Date: Tue, 5 Mar 2019 20:14:13 +0800 Subject: [PATCH] fix#158 do not delete session resouces dir in close session (#159) --- .../scala/yaooqinn/kyuubi/session/KyuubiSession.scala | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/kyuubi-server/src/main/scala/yaooqinn/kyuubi/session/KyuubiSession.scala b/kyuubi-server/src/main/scala/yaooqinn/kyuubi/session/KyuubiSession.scala index 29d32a593..d5a33a8d9 100644 --- a/kyuubi-server/src/main/scala/yaooqinn/kyuubi/session/KyuubiSession.scala +++ b/kyuubi-server/src/main/scala/yaooqinn/kyuubi/session/KyuubiSession.scala @@ -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 {