Hi Guarav, The updated nodes reported in the AllocateResponse are not those that have had containers allocated on them recently for the application. Rather, they're the ones whose status in the cluster has changed, e.g. those that have recently connected, become unhealthy, or disconnected.
hope that helps, Sandy On Tue, Feb 11, 2014 at 11:29 AM, Gaurav Gupta <[email protected]>wrote: > I am using Hadoop 2.2.0 Version > > hadoop@node14:~$ hadoop version > Hadoop 2.2.0 > Subversion https://svn.apache.org/repos/asf/hadoop/common -r 1529768 > Compiled by hortonmu on 2013-10-07T06:28Z > Compiled with protoc 2.5.0 > > -----Original Message----- > From: Gaurav Gupta [mailto:[email protected]] > Sent: Tuesday, February 11, 2014 11:16 AM > To: [email protected] > Subject: Getting Updated Node Report from AllocateResponse > > Hi, > > > > I am trying to get the list of nodes whose status has been updated from the > AllocateResponse Obj, but I get back empty list although containers are > allocated to my App Master. Here is the code snippet for the same > > > > for (ContainerRequest cr : containerRequests) { > > LOG.info("Requested container: {}", cr.toString()); > > amRmClient.addContainerRequest(cr); > > } > > for (ContainerId containerId : releasedContainers) { > > LOG.info("Released container, id={}", containerId.getId()); > > amRmClient.releaseAssignedContainer(containerId); > > } > > AllocateResponse amResp = amRmClient.allocate(0); > > List<Container> newAllocatedContainers = amResp.getAllocatedContainers(); > > List<NodeReport> updatedNodes = amResp.getUpdatedNodes(); > > > > I always empty list in the last call. Any pointers? > > > > Thanks > > -Gaurav > > > > >
