reef-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dhruv Mahajan (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (REEF-1392) Adding IObserver<ICloseEvent> for IMRU tasks
Date Fri, 20 May 2016 20:21:13 GMT

    [ https://issues.apache.org/jira/browse/REEF-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294117#comment-15294117
] 

Dhruv Mahajan commented on REEF-1392:
-------------------------------------

As per our offline discussions, this happens because StreamingTransportServer is running in
another thread and if it fails because StreamingLink throws exception we cannot capture it
in out map and update host tasks. For now this might be ok thing to do. But eventually we
need a good solution to this. GC layer and Wake Remote layer needs to be modified to handle
faults and failures gracefully. 

> Adding IObserver<ICloseEvent> for IMRU tasks
> --------------------------------------------
>
>                 Key: REEF-1392
>                 URL: https://issues.apache.org/jira/browse/REEF-1392
>             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
(v6.3.4#6332)

Mime
View raw message