HeartSaVioR commented on issue #24936: [SPARK-24634][SS] Add a new metric regarding number of rows later than watermark URL: https://github.com/apache/spark/pull/24936#issuecomment-504471573 As I stated in SPARK-28074 - #24890, this could be used as an indicator of unexpected discarded rows due to watermark, especially between multiple stateful operators. DiscardLateRowsExec doesn't implement CodegenSupport yet. As FilterExec implements CodegenSupport and DiscardLateRowsExec is simpler version of FilterExec, I guess I could address it. I'll try it out.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
