This is a subtle bug in which the main thread sometimes hangs waiting to read the next record from the input file. This appears to occur only under a strictly-regulated memory cap such as on cluster environment.
To address this, I have so far added the following:
Set the default batch size based on the queue sizes
Warn the user if their combination of batch and queue sizes might lead to excessive memory usage
This is a subtle bug in which the main thread sometimes hangs waiting to read the next record from the input file. This appears to occur only under a strictly-regulated memory cap such as on cluster environment.
To address this, I have so far added the following: