Description
For fault tolerant, IMRU tasks, MapTaskHost and UpdateTaskHost should implement IObserver<ICloseEvent>. When they receive ICloseEvent, it will verify if the closing event is send from driver based on the message in the event, then trow IMRUTaskException with a define message to inform the driver it is closed.
The change should be backward compatible. If the the IMRU tasks are not bound to the task configuration for TaskConfiguration.OnClose, the event won't be received.
Attachments
Issue Links
- contains
-
REEF-1404 IMRU task state Maintenance and Preservation in Evaluator for fault tolerant
- Resolved
- Is contained by
-
REEF-1223 IMRU Fault Tolerance - restart failed evaluators
- Resolved
- is related to
-
REEF-1223 IMRU Fault Tolerance - restart failed evaluators
- Resolved
-
REEF-1386 Adding ICloseEvent handler for IMRU task
- Resolved
- relates to
-
REEF-1408 Creat IMRU functional test infrastructure and add tests for IMRU Task close handler
- Resolved