aokolnychyi commented on code in PR #49493:
URL: https://github.com/apache/spark/pull/49493#discussion_r1915914645
##########
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2Commands.scala:
##########
@@ -317,6 +331,24 @@ case class WriteDelta(
override lazy val references: AttributeSet = query.outputSet
+ lazy val inputRowAttrs: Seq[Attribute] = {
Review Comment:
The biggest change here is that we use column ordinals from projections to
find actual input attributes instead of relying on fake schemas from
projections (which we expected but did not enforce/validate before).
--
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]
