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

Rajesh Balamohan commented on TEZ-2672:
---------------------------------------

Thanks for sharing the patch [~abstractdog] . It may be easier to expose 
"getConf" in "DagInfo" to fix this issue.

[https://github.com/apache/tez/blob/master/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java]

[https://github.com/apache/tez/blob/master/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java]

 

DAGImpl takes care of setting the relevant configs (user can specify DAG 
related prop in setDagConf).

[https://github.com/apache/tez/blob/master/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java#L520]

[https://github.com/apache/tez/blob/master/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java#L617]

 

TezTaskCommunicatorImpl should be able to access this config via the context.

 

 

 

 

 

> Allow specifying a new payload for plugins when a new DAG starts
> ----------------------------------------------------------------
>
>                 Key: TEZ-2672
>                 URL: https://issues.apache.org/jira/browse/TEZ-2672
>             Project: Apache Tez
>          Issue Type: Sub-task
>    Affects Versions: TEZ-2003
>            Reporter: Siddharth Seth
>            Assignee: László Bodor
>            Priority: Major
>         Attachments: TEZ-2672.01.patch, TEZ-2672.02.patch
>
>
> This can include information specific to the DAG - constant query 
> identifiers, etc.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to