Interview Guides

You're working on a PySpark pipeline and notice that some stages run much slower than others because a small number of keys dominate the data. You want to reason about how to diagnose and reduce skew before it causes repeated job delays.
How do you handle data skewness in a PySpark environment?