Github user justinrmiller commented on the issue:
https://github.com/apache/spark/pull/20572
Otherwise the job crashes, even for gaps of one or two messages on a couple
of partitions (and while fail hard is a good philosophy, in this case it's not
really practical for us) so it's
Github user justinrmiller commented on the issue:
https://github.com/apache/spark/pull/20572
Do you think it would be possible for this to go into 2.3.0?
---
-
To unsubscribe, e-mail: reviews-unsubscr
Github user justinrmiller commented on the issue:
https://github.com/apache/spark/pull/20572
Not to pile on, but I was encountering non-consecutive offsets on
non-compacted topics once or twice a day at our volume. This patch fixes this
(haven't had a problem with it since) and I'm
Github user justinrmiller commented on the issue:
https://github.com/apache/spark/pull/20572
This looks good to me.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail
