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?