diff --git a/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala b/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala index d0fb201a6..135cc6dbd 100644 --- a/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala +++ b/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala @@ -548,7 +548,7 @@ trait FlintJobExecutor { } def getSegmentName(sparkSession: SparkSession): String = { - val maxExecutorsCount = sparkSession.conf.get(FlintSparkConf.MAX_EXECUTORS_COUNT.key) + val maxExecutorsCount = sparkSession.conf.get(FlintSparkConf.MAX_EXECUTORS_COUNT.key, "unknown") String.format("%se", maxExecutorsCount) }