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

Junping Du commented on YARN-4893:
----------------------------------

Thanks [~brahmareddy] for updating the patch.
Instead of removing exception throw in drianEvents():
{noformat}
@@ -153,9 +153,7 @@ public void drainEvents() {
     Dispatcher rmDispatcher = getRmDispatcher();
     if (rmDispatcher instanceof DrainDispatcher) {
       ((DrainDispatcher) rmDispatcher).await();
-    } else {
-      throw new UnsupportedOperationException("Not a Drain Dispatcher!");
-    }
+    } 
   }
{noformat}

Shall we replace AsyncDispatcher in TestNodeListManager with DrainDispatcher 
instead?
{code}
  private Dispatcher getDispatcher() {
    Dispatcher dispatcher = new AsyncDispatcher() {
{code}

IMO, the previous way of fix could make drainEvents() failed silently (if not a 
DrainDispatcher), that potentially make test failure harder to debug in future.

> Fix some intermittent test failures in TestRMAdminService
> ---------------------------------------------------------
>
>                 Key: YARN-4893
>                 URL: https://issues.apache.org/jira/browse/YARN-4893
>             Project: Hadoop YARN
>          Issue Type: Bug
>            Reporter: Junping Du
>            Assignee: Brahma Reddy Battula
>            Priority: Blocker
>         Attachments: YARN-4893-002.patch, YARN-4893.patch
>
>
> As discussion in YARN-998, we need to add rm.drainEvents() after 
> rm.registerNode() or some of test could get failed intermittently. Also, we 
> can consider to add rm.drainEvents() within rm.registerNode() that could be 
> more convenient.



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

Reply via email to