reef-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Julia (JIRA)" <>
Subject [jira] [Commented] (REEF-1392) Adding IObserver<ICloseEvent> for IMRU tasks
Date Wed, 18 May 2016 18:47:13 GMT


Julia commented on REEF-1392:

This close is enforced by driver when something is wrong in fault tolerant case. If we would
like the task to complete current iteration then return from Call() properly, 
1. We need to modify IMRU task call() method to work together with the close event handler
to determine how the call method will get notified and when to finish. 
2. If the Call() returns properly after some interactions, what we received at driver side
would be ICompeletedtask event. Driver won't be able to know if the task is really completed
or enforced to be closed. 
Shall we leave this work until we work on check point? In the check point scenario, we do
need to complete current iteration and remember the state. For the current stage, we just
need the task to send failed event back. 

> Adding IObserver<ICloseEvent> for IMRU tasks
> --------------------------------------------
>                 Key: REEF-1392
>                 URL:
>             Project: REEF
>          Issue Type: Task
>            Reporter: Julia
>            Assignee: Julia
>              Labels: FT
> 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. 

This message was sent by Atlassian JIRA

View raw message