Re: NullPointerException : (Channel closed) on writeCheckpoint

[Jay Vyas]

Alas - i cannot reproduce this bug anymore., maybe as a first pass it would
be better to look into the batchSize parameter and understand how it works
a little better.

Any good docs on the way batchSize changes the source behaviour?