tdas commented on issue #27333: [SPARK-29438][SS][FOLLOWUP] Add regression tests for Streaming Aggregation and flatMapGroupsWithState URL: https://github.com/apache/spark/pull/27333#issuecomment-580616641 As is the test look good. I would just test one more thing. If possible, introduce the same bug in aggregate and mapGroupsWithState and see whether these tests fail. You may be able to introduce this by inject the incorrect partition id in the StateStoreRDD when getting the state store.
---------------------------------------------------------------- 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]
