RequestToSync RPC Message¶
RequestToSync is a BarrierCoordinatorMessage to start Global Sync phase.
RequestToSync is sent out from BarrierTaskContext (i.e., barrier tasks on executors) to a BarrierCoordinator (on the driver) to handle.
| Operation | Message | Request Message |
|---|---|---|
| allGather | User-defined message | ALL_GATHER |
| barrier | empty | BARRIER |
Creating Instance¶
RequestToSync takes the following to be created:
- Number of tasks (partitions)
- Stage ID
- Stage Attempt ID
- Task Attempt ID
- BarrierEpoch
- Partition ID
- Message
- RequestMethod
RequestToSync is created when:
BarrierTaskContextis requested for a Global Sync