[VL] minor change for fallback log

apache · Dec 1, 2023 · 795fc23 · 795fc23
1 parent 84b5d30
commit 795fc23
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/gluten-core/src/main/scala/org/apache/spark/sql/execution/GlutenFallbackReporter.scala b/gluten-core/src/main/scala/org/apache/spark/sql/execution/GlutenFallbackReporter.scala
@@ -47,7 +47,10 @@ case class GlutenFallbackReporter(glutenConfig: GlutenConfig, spark: SparkSessio
   }
 
   private def logFallbackReason(logLevel: String, nodeName: String, reason: String): Unit = {
-    logOnLevel(logLevel, s"Validation failed for plan: $nodeName, due to: $reason.")
+    val executionIdInfo = Option(spark.sparkContext.getLocalProperty(SQLExecution.EXECUTION_ID_KEY))
+      .map(id => s"[QueryId=$id]")
+      .getOrElse("")
+    logOnLevel(logLevel, s"Validation failed for plan: $nodeName$executionIdInfo, due to: $reason.")
   }
 
   private def printFallbackReason(plan: SparkPlan): Unit = {