diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProcessBuilder.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProcessBuilder.scala index 0e35c85ba..9789baa4e 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProcessBuilder.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProcessBuilder.scala @@ -19,14 +19,12 @@ package org.apache.kyuubi.engine.trino import java.net.URI import java.nio.file.Files -import java.nio.file.Path import java.nio.file.Paths import org.apache.kyuubi.KYUUBI_VERSION import org.apache.kyuubi.KyuubiSQLException import org.apache.kyuubi.Logging import org.apache.kyuubi.SCALA_COMPILE_VERSION -import org.apache.kyuubi.Utils import org.apache.kyuubi.config.KyuubiConf import org.apache.kyuubi.config.KyuubiConf.ENGINE_TRINO_CONNECTION_CATALOG import org.apache.kyuubi.config.KyuubiConf.ENGINE_TRINO_CONNECTION_URL @@ -114,32 +112,6 @@ class TrinoProcessBuilder( override protected def commands: Array[String] = Array(executable) - override protected val workingDir: Path = { - env.get("KYUUBI_WORK_DIR_ROOT").map { root => - val workingRoot = Paths.get(root).toAbsolutePath - if (!Files.exists(workingRoot)) { - debug(s"Creating KYUUBI_WORK_DIR_ROOT at $workingRoot") - Files.createDirectories(workingRoot) - } - if (Files.isDirectory(workingRoot)) { - workingRoot.toString - } else null - }.map { rootAbs => - val working = Paths.get(rootAbs, proxyUser) - if (!Files.exists(working)) { - debug(s"Creating $proxyUser's working directory at $working") - Files.createDirectories(working) - } - if (Files.isDirectory(working)) { - working - } else { - Utils.createTempDir(rootAbs, proxyUser) - } - }.getOrElse { - Utils.createTempDir(namePrefix = proxyUser) - } - } - override def toString: String = commands.map { case arg if arg.startsWith("--") => s"\\\n\t$arg" case arg => arg