Github user jose-torres commented on the issue:
https://github.com/apache/spark/pull/21490
What's the motivation for this change? Does something go wrong if they
aren't initialized correctly? (And note that we document that the socket
source doesn't support fault recovery at all - not sure whether that should
affect this PR.)--- --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
