From 5dfdf96c33b30f40391927a3178a7d8d1067d964 Mon Sep 17 00:00:00 2001 From: Fei Wang Date: Thu, 25 Jan 2024 11:02:42 -0800 Subject: [PATCH] comments --- .../engine/spark/session/SparkSQLSessionManager.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSQLSessionManager.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSQLSessionManager.scala index 3d44fc8b608..b6768c6971d 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSQLSessionManager.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSQLSessionManager.scala @@ -17,6 +17,7 @@ package org.apache.kyuubi.engine.spark.session +import java.nio.file.Paths import java.util.concurrent.{ScheduledExecutorService, TimeUnit} import org.apache.hadoop.fs.Path @@ -211,17 +212,16 @@ class SparkSQLSessionManager private (name: String, spark: SparkSession) override protected def isServer: Boolean = false private[spark] def getEngineResultSavePath(): String = { - Seq(conf.get(OPERATION_RESULT_SAVE_TO_FILE_DIR), engineId).mkString(Path.SEPARATOR) + Paths.get(conf.get(OPERATION_RESULT_SAVE_TO_FILE_DIR), engineId).toString } private def getSessionResultSavePath(sessionHandle: SessionHandle): String = { - Seq(getEngineResultSavePath(), sessionHandle.identifier.toString).mkString(Path.SEPARATOR) + Paths.get(getEngineResultSavePath(), sessionHandle.identifier.toString).toString } private[spark] def getOperationResultSavePath( sessionHandle: SessionHandle, opHandle: OperationHandle): String = { - Seq(getSessionResultSavePath(sessionHandle), opHandle.identifier.toString).mkString( - Path.SEPARATOR) + Paths.get(getSessionResultSavePath(sessionHandle), opHandle.identifier.toString).toString } }