Github user viirya commented on the issue:
https://github.com/apache/spark/pull/22524
hmm, in above suggested way, isn't `setStopEarly(true)` called when
consuming `given_limit` + 1 records? Otherwise I may misunderstand it?--- --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
