Yeah it looks like it is using the Async transport executor, which doesn't make much sense in this context, IMO.  Unfortunately this whole part looks like it would do much better if we had it working with the ForkJoinPool as another task, so that it would block other map phases if the combiner was being too slow.