To me it appears the double shuffling was solved by changing map and mapToPair to mapPartitions and mapPartitionsToPair, respectively. I don't think the explicit declaration of the HashPartitioner has any effect.
[ Full content available at: https://github.com/apache/beam/pull/6181 ] This message was relayed via gitbox.apache.org for [email protected]
