Use map+merge instead of flatMap for higher parallelism