Thanks Hitesh, I only found onShutdownRequest is called
when ApplicationAttemptNotFoundException happens.
AllocateResponse#AMCommand is never checked.
AMRMClientAsyncImpl#HeartbeatThread
try {
response = client.allocate(progress);
} catch (ApplicationAttemptNotFoundException e) {
handler.onShutdownRequest();
LOG.info("Shutdown requested. Stopping callback.");
return;
}
On Fri, Aug 14, 2015 at 4:37 AM, Hitesh Shah <[email protected]> wrote:
> Please look at CallbackHandler::onShutdownRequest()
>
> thanks
> — Hitesh
>
> On Aug 13, 2015, at 6:55 AM, Jeff Zhang <[email protected]> wrote:
>
> > I see that AllocateResponse has AMCommand which may request AM to resync
> or shutdown, but I don't see AMRMClientAsync#CallbackHandler has any method
> to handle that. Should AMRMClientAsync#CallbackHandler add method
> onAMCommand ?
> >
> > --
> > Best Regards
> >
> > Jeff Zhang
>
>
--
Best Regards
Jeff Zhang
