[SPARK-26268] Decouple shuffle data from Spark deployment

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 3.1.0
• Component/s: Shuffle, Spark Core
• Assignee: Unassigned
• Reporter: Ben Sidhom
• Created: 04/Dec/18 22:31
• Updated: 17/May/20 18:31

Description

Right now the batch scheduler assumes that shuffle data is tied to executors. As a result, when an executor is lost, any map tasks that ran on that executor are rescheduled unless the "external" shuffle service is being used. Note that this service is only external in the sense that it does not live within executors themselves; its implementation cannot be swapped out and it is assumed to speak the BlockManager language.

The following changes would facilitate external shuffle (see SPARK-25299 for motivation):

• Do not rerun map tasks on lost executors when shuffle data is stored externally. For example, this could be determined by a property or by an additional method that all ShuffleManagers implement.
• Do not assume that shuffle data is stored in the standard BlockManager format or that a BlockManager is or must be available to ShuffleManagers.

Note that only the first change is actually required to realize the benefits of remote shuffle implementations as a phony (or null) BlockManager can be used by shuffle implementations.

Issue Links

• blocks: SPARK-25299 Use remote storage for persisting shuffle data
• links to: GitHub Pull Request #24462