Github user viirya commented on the issue:
https://github.com/apache/spark/pull/22524
Thanks @mgaido91. Resetting a flag in blocking operators is feasible
solution I think for now to solve this issue that limit operator consumes all
inputs. For current blocking operators, we should add enough regression tests.
I think we won't frequently add new operators, although I agree that the
maintenance might be a potential issue.
I'm not sure about a global boolean is significant different than current
flag. This flag is already a global boolean variable.
Fortunately I think this might not be so urgent to fix (is it?), so we may
be able to wait for more options.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
