YARN-4400. AsyncDispatcher.waitForDrained should be final. Contributed by Daniel Templeton.
This commit is contained in:
parent
882f2f0464
commit
bb5df272b9
@ -1182,6 +1182,9 @@ Release 2.8.0 - UNRELEASED
|
|||||||
YARN-4477. FairScheduler: Handle condition which can result in an
|
YARN-4477. FairScheduler: Handle condition which can result in an
|
||||||
infinite loop in attemptScheduling. (Tao Jie via asuresh)
|
infinite loop in attemptScheduling. (Tao Jie via asuresh)
|
||||||
|
|
||||||
|
YARN-4400. AsyncDispatcher.waitForDrained should be final. (Daniel Templeton
|
||||||
|
via junping_du)
|
||||||
|
|
||||||
Release 2.7.3 - UNRELEASED
|
Release 2.7.3 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -59,7 +59,7 @@ public class AsyncDispatcher extends AbstractService implements Dispatcher {
|
|||||||
// Indicates all the remaining dispatcher's events on stop have been drained
|
// Indicates all the remaining dispatcher's events on stop have been drained
|
||||||
// and processed.
|
// and processed.
|
||||||
private volatile boolean drained = true;
|
private volatile boolean drained = true;
|
||||||
private Object waitForDrained = new Object();
|
private final Object waitForDrained = new Object();
|
||||||
|
|
||||||
// For drainEventsOnStop enabled only, block newly coming events into the
|
// For drainEventsOnStop enabled only, block newly coming events into the
|
||||||
// queue while stopping.
|
// queue while stopping.
|
||||||
|
Loading…
Reference in New Issue
Block a user