karuppayya commented on code in PR #52157:
URL: https://github.com/apache/spark/pull/52157#discussion_r2309281026
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala:
##########
@@ -150,7 +150,7 @@ class QueryExecution(
// with the rest of processing of the root plan being just outputting
command results,
// for eagerly executed commands we mark this place as beginning of
execution.
tracker.setReadyForExecution()
- val qe = sparkSession.sessionState.executePlan(p, mode)
+ val qe = sparkSession.sessionState.executePlan(p, mode,
shuffleCleanupMode)
Review Comment:
This seems to have been introduced
[here](https://github.com/apache/spark/pull/16826/files#diff-a85ac8fb9444ec88578cd15848b96eaf80ce075ed7b5de9770d71c64fd44f545R51).
It doesnt mention the rationale behind. But like you mentioned it does nt
serve any real purpose, creating new QueryExecution
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
