hadoop-yarn-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bikas Saha (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (YARN-1121) RMStateStore should flush all pending store events before closing
Date Tue, 05 Nov 2013 06:16:18 GMT

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

Bikas Saha commented on YARN-1121:

There are 3 new booleans with 8 combinations possible between them. Which combinations are
legal? Which are impossible? Some comments will help understand their interaction. Naming
could be better. e.g. drainEventsOnStop instead of drainingStopNeeded and drainOnStop instead
of drainingStop.
+  private volatile boolean drained = true;
+  private volatile boolean drainingStopNeeded = false;
+  private volatile boolean drainingStop = false;

Typo {code} +      LOG.info("Ignoring events as AsyncDispatcher is draning to stop."); {code}

Isnt this almost a tight loop? Given that storing stuff will be over the network and slow,
why not have a wait notify between this thread and the draining thread?

DrainEventHandler sounds misleading. It doesnt really drain. It ignores or drops events. The
other thing we can do is take a count of the number of pending events to drain at service
stop. Then make sure we drain only those many, thus ignoring the new ones. This removes the
need of drainingStop and reduces the combinatorics of booleans.

> RMStateStore should flush all pending store events before closing
> -----------------------------------------------------------------
>                 Key: YARN-1121
>                 URL: https://issues.apache.org/jira/browse/YARN-1121
>             Project: Hadoop YARN
>          Issue Type: Sub-task
>          Components: resourcemanager
>    Affects Versions: 2.1.0-beta
>            Reporter: Bikas Saha
>            Assignee: Jian He
>             Fix For: 2.2.1
>         Attachments: YARN-1121.1.patch, YARN-1121.2.patch, YARN-1121.2.patch, YARN-1121.3.patch,
YARN-1121.4.patch, YARN-1121.5.patch
> on serviceStop it should wait for all internal pending events to drain before stopping.

This message was sent by Atlassian JIRA

View raw message