Are you sure this is correct? It seems like f2 will put the entire queue into `b` as an element in queue `a`. Try it with an RDD with more than one partition.