jerrypeng commented on code in PR #52729: URL: https://github.com/apache/spark/pull/52729#discussion_r2479348705
########## sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala: ########## @@ -284,6 +284,8 @@ trait StreamTest extends QueryTest with SharedSparkSession with TimeLimits with case class WaitUntilBatchProcessed(batchId: Long) extends StreamAction with StreamMustBeRunning + case object WaitUntilCurrentBatchProcessed extends StreamAction with StreamMustBeRunning Review Comment: This waits until the **current** batch finishes. It is just an easier API to use for testing when we just need to wait for the current batch to finish and not for a specific batch to finish. -- 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]
