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

Siddharth Seth commented on TEZ-1967:
-------------------------------------

bq. Then from third comment, sorry I don't get "capping" for timeout.
Sorry I meant capping the sleep. The sleep interval should not be larger than 
the timeout specified.

bq.  For your fourth comment, in the client side the left over time passing to 
AM is done after the while loop. so you to move into loop/above condition? 
The leftover time should only be required if the AM is in a RUNNING state. The 
condition for all 4 states should change as mentioned in the previous comment.

> Add a monitoring API on DAGClient which returns after a time interval or on 
> DAG state change
> --------------------------------------------------------------------------------------------
>
>                 Key: TEZ-1967
>                 URL: https://issues.apache.org/jira/browse/TEZ-1967
>             Project: Apache Tez
>          Issue Type: Improvement
>    Affects Versions: 0.7.0
>            Reporter: Siddharth Seth
>            Assignee: Vasanth kumar RJ
>         Attachments: TEZ-1967-InitialReview.patch, TEZ-1967.1.patch, 
> TEZ-1967.2.patch, TEZ-1967.3.patch
>
>
> To monitor a running DAG, clients end up using DAGClient.getDAGSstatus in a 
> loop with a poll interval.
> In the worst case, they find out about DAG completion, failure etc only after 
> the poll interval.
> Instead, an API can be added which waits on the AM for a specified interval, 
> but can return earlier if the DAG state changes.
> This will end up blocking RPC handlers - but that isn't a problem since we 
> don't have many entities querying for DAG status.



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

Reply via email to