[jira] [Created] (REEF-1687) Throw exception if task dispose throws exception after Call()

["Julia (JIRA)" <ji...@apache.org>]

Julia created REEF-1687:
---------------------------

             Summary: Throw exception if task dispose throws exception after Call()
                 Key: REEF-1687
                 URL: https://issues.apache.org/jira/browse/REEF-1687
             Project: REEF
          Issue Type: Bug
            Reporter: Julia


Currently in TaskRuntime, when Dispose a task in Close method, if exception happens, we throw exception. While when dispose the task after calling Call() method, we just log but swallow the exception. This is inconsistent. It also result in TestFailMapperTasksOnDispose randomly fails because it really depends on which code path is quicker that determines where the task Dispose is called. 

When Task Dispose throw exception, that means some resources are not released properly. For fault tolerant, even if the task is returned from the Call(), either realy completed the task or clsoedByDriver, if we are to reuse the evaluator to resubmit a task on it, it is not right. So the correct way is to throw exception to make evaluator fail, same as what we did in close() method. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)