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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org