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 135cc6dbd..586f25f0c 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,8 @@ trait FlintJobExecutor { } def getSegmentName(sparkSession: SparkSession): String = { - val maxExecutorsCount = sparkSession.conf.get(FlintSparkConf.MAX_EXECUTORS_COUNT.key, "unknown") + val maxExecutorsCount = + sparkSession.conf.get(FlintSparkConf.MAX_EXECUTORS_COUNT.key, "unknown") String.format("%se", maxExecutorsCount) }