sahnib commented on code in PR #46825: URL: https://github.com/apache/spark/pull/46825#discussion_r1636698711
########## sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithListStateSuite.scala: ########## Review Comment: `TransformWithStateExec` currently returns `true` for ProcessingTime timeMode in `shouldRunAnotherBatch`. (Note that this behavior is same as FMGWS). I had to add a manual clock to ensure that data processing is triggerred before Check/Expect blocks (otherwise AddData does not finish). Let me know if that answers your question. ########## sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithMapStateSuite.scala: ########## Review Comment: https://github.com/apache/spark/pull/46825#discussion_r1636698711 -- 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]
