Description
DataSkewPolicy should be able to handle job DAG with multiple shuffles. For this, we need to modify DataSkewRuntimePass so that the target optimization edge can be identified via ExecutionProperty.
Attachments
Issue Links
- blocks
-
NEMO-64 Fix map stage hang under DataSkewPolicy
- Resolved