Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22524
I didn't look into it, but we can change `if (count < given_limit)` to `if
(count < given_limit - 1)` if you are right.
My focus is the code template, without the `if else`, how can the
downstream operators stop consuming data?--- --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
