Description
when run fetch in hadoop with multiple concurrent mapper, there are multiple independent fetchQueues that make hard to manage them. i suggest that construct fetchQueues before begin of run with this line:
feeder = new QueueFeeder(input, fetchQueues, threadCount * 50);