The sequence of events is as under :
- RM is stopped while putting a RMStateStore Event to RMStateStore's AsyncDispatcher. This leads to an Interrupted Exception being thrown.
- As RM is being stopped, RMStateStore's AsyncDispatcher is also stopped. On serviceStop, we will check if all events have been drained and wait for event queue to drain(as RM State Store dispatcher is configured for queue to drain on stop).
- This condition never becomes true and AsyncDispatcher keeps on waiting incessantly for dispatcher event queue to drain till JVM exits.
Initial exception while posting RM State store event to queue
JStack of AsyncDispatcher hanging on stop
We keep on getting below logs