Github user jose-torres commented on the issue:
https://github.com/apache/spark/pull/21063
The approach looks good to me, but we probably want to add some tests to
StreamingQueryStatusAndProgressSuite. (See test("basic") in ContinuousSuite for
how to set up a continuous processing memory stream, and note that
processAllAvailable() won't work properly for continuous execution - you'll
want to use CheckAnswer to await the added data and Execute to do the
test-specific progress checks)
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
