diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala index ff96ef4f9..108dd2dc6 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala @@ -168,6 +168,8 @@ object SparkSQLEngine extends Logging { if (Utils.isOnK8s) { kyuubiConf.setIfMissing(FRONTEND_CONNECTION_URL_USE_HOSTNAME, false) + val podNamePrefix = s"kyuubi-${user}-${Instant.now().toEpochMilli}" + _sparkConf.setIfMissing("spark.kubernetes.executor.podNamePrefix", podNamePrefix) } // Set web ui port 0 to avoid port conflicts during non-k8s cluster mode