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

Jeff Zhang commented on TEZ-1703:
---------------------------------

[~sseth] Thanks for your review and suggestion.

You are right, catch the exception in RootInputInitializerManager and send 
VertexEventRootInputFailed would be much more simple and clean.
I attach a new patch, please help review.

bq. Does DAG have to change to add getAppContext() ?
Revert the change as we don't need it in the new patch.

> Exception handling for InputInitializer
> ---------------------------------------
>
>                 Key: TEZ-1703
>                 URL: https://issues.apache.org/jira/browse/TEZ-1703
>             Project: Apache Tez
>          Issue Type: Bug
>    Affects Versions: 0.5.1
>            Reporter: Jeff Zhang
>         Attachments: TEZ-1703-2.patch, TEZ-1703.patch
>
>
> For handleInputInitializerEvent - this should be fairly straightfoward to 
> handle. At the moment this is an inline call from within the AsyncDispatcher, 
> and will end up causing a RuntimeException. The RuntimeException can be 
> changed to a AMUserCodeException which will take care of this.
> For onVertexStateUpdated, this eventually gets invoked from within 
> RootInputInitializerManager. Catching exceptions there and sending a 
> RootInputInitialzierFailedEvent should be enough to fix this ? May require 
> some state machine changes to handle this event on a few more states.



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

Reply via email to