dongjoon-hyun opened a new pull request, #37108:
URL: https://github.com/apache/spark/pull/37108

   ### What changes were proposed in this pull request?
   
   This is a back port of https://github.com/apache/spark/pull/36953
   
   This PR adds a check for invalid plans in AQE replanning process. The check 
will throw exceptions when it detects an invalid plan, causing AQE to void the 
current replanning result and keep using the latest valid plan.
   
   ### Why are the changes needed?
   
   AQE logical optimization rules can lead to invalid physical plans and cause 
runtime exceptions as certain physical plan nodes are not compatible with 
others. E.g., `BroadcastExchangeExec` can only work as a direct child of 
broadcast join nodes, but it could appear under other incompatible physical 
plan nodes because of empty relation propagation.
   
   ### Does this PR introduce _any_ user-facing change?
   
   No.
   
   ### How was this patch tested?
   
   Added UT.


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to