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

Hudson commented on YARN-2432:
------------------------------

SUCCESS: Integrated in Hadoop-Hdfs-trunk-Java8 #6 (See 
[https://builds.apache.org/job/Hadoop-Hdfs-trunk-Java8/6/])
YARN-2432. RMStateStore should process the pending events before close. 
Contributed by Varun Saxena (jianhe: rev 
9b860661a5754e829bd8c34ef092757421589bbe)
* hadoop-yarn-project/CHANGES.txt
* 
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/RMStateStore.java


> RMStateStore should process the pending events before close
> -----------------------------------------------------------
>
>                 Key: YARN-2432
>                 URL: https://issues.apache.org/jira/browse/YARN-2432
>             Project: Hadoop YARN
>          Issue Type: Bug
>          Components: resourcemanager
>            Reporter: Varun Saxena
>            Assignee: Varun Saxena
>             Fix For: 2.7.0
>
>         Attachments: YARN-2432.patch
>
>
> Refer to discussion on YARN-2136 
> (https://issues.apache.org/jira/browse/YARN-2136?focusedCommentId=14097266&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14097266).
>  
> As pointed out by [~jianhe], we should process the dispatcher event queue 
> before closing the state store by flipping over the following statements in 
> code.
> {code:title=RMStateStore.java|borderStyle=solid}
>  protected void serviceStop() throws Exception {
>     closeInternal();
>     dispatcher.stop();
>   }
> {code}
> Currently, if the state store is being stopped on events such as switching to 
> standby, it will first close the state store(in case of ZKRMStateStore, close 
> connection with ZK) and then process the pending events. Instead, we should 
> first process the pending events and then call close.



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

Reply via email to