shuffle – Tantus Data

Spark shuffle – Case #2 – repartitioning skewed data

15 October 201815 October 2018 by

In the previous blog entry we reviewed a Spark scenario where calling the partitionBy method resulted in each task creating as many files as you had days of events in your dataset (which was too much and caused problems). We fixed that by calling the repartition method. But will repartitioning your dataset always be enough? […]

partitionby, repartition, shuffle, spark

Spark shuffle – Case #1 – partitionBy and repartition

10 June 20186 October 2018 by

Marcin

This is the first of a series of articles explaining the idea of how the shuffle operation works in Spark and how to use this knowledge in your daily job as a data engineer or data scientist. It will be a case-by-case explanation, so I will start with showing you a code example which does […]