Github user arunmahadevan commented on the issue:
https://github.com/apache/spark/pull/21490
The patch does not attempt to make the micro-batch text-socket source fault
tolerant and I suppose that may not be very trivial.
This just makes the source work when query is restarted allowing one to
play with the sate in example programs (and could even produce correct results
if the restart is done gracefully). Not allowing restarts may be too
restrictive IMO.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
