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

Jeff Zhang commented on TEZ-1631:
---------------------------------

One thing need to be careful is that in the high level component, 
TezSession.stop() will throw exception if AM is session timeout.  So in that 
case either don't call TezSession.stop() or add try-catch around 
TezSession.stop().

> Session dag submission timeout can result in duplicate DAG submissions
> ----------------------------------------------------------------------
>
>                 Key: TEZ-1631
>                 URL: https://issues.apache.org/jira/browse/TEZ-1631
>             Project: Apache Tez
>          Issue Type: Bug
>    Affects Versions: 0.4.1
>            Reporter: Bikas Saha
>            Assignee: Jeff Zhang
>         Attachments: Tez-1631.patch
>
>
> In TezSession.submitDAG() we could first check if the session is ready and 
> throw a SessionNotRunning exception if that is not the case. This should be 
> done before processing the DAG and thus will prevent unnecessary modification 
> of the DAG.
> If the session is ready then we can submit the DAG as usual. Higher level 
> components already handle SessionNotRunning exception.



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

Reply via email to