fixup

apache · Sep 23, 2024 · c6bd03a · c6bd03a
1 parent c85da41
commit c6bd03a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala
@@ -97,7 +97,7 @@ class QueryExecution(
 
   def analyzed: LogicalPlan = lazyAnalyzed.get
 
-  private val lazyCommandExecuted = Lazy {
+  private val lazyCommandExecuted = LazyTry {
     mode match {
       case CommandExecutionMode.NON_ROOT => analyzed.mapChildren(eagerlyExecuteCommands)
       case CommandExecutionMode.ALL => eagerlyExecuteCommands(analyzed)
@@ -240,7 +240,7 @@ class QueryExecution(
    * Given QueryExecution is not a public class, end users are discouraged to use this: please
    * use `Dataset.rdd` instead where conversion will be applied.
    */
-  def toRDD: RDD[InternalRow] = lazyToRdd.get
+  def toRdd: RDD[InternalRow] = lazyToRdd.get
 
   /** Get the metrics observed during the execution of the query plan. */
   def observedMetrics: Map[String, Row] = CollectMetricsExec.collect(executedPlan)