HeartSaVioR commented on PR #44688:
URL: https://github.com/apache/spark/pull/44688#issuecomment-1895641773

   @cloud-fan 
   It does not seem to be easy fix - I have a hard time debugging on this:
   
   
https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/EventTimeWatermarkExec.scala
   
   eventTime in the constructor does not seem to match with child.output via 
semanticEquals. Does canonicalization care about making child.output and 
attribute referring child.output in sync after canonicalization? Otherwise I 
expect the fix to be very involved and current fix of the PR sounds to me as 
reasonable workaround.


-- 
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