hopRMNodeCompObject
= (RMNodeComps) NdbEventStreamingReceiver.blockingQueue.take();
if (hopRMNodeCompObject != null) {
if (LOG.isDebugEnabled()) {
printHopsRMNodeComps(hopRMNodeCompObject);
<BUG>}
RMNode rmNode=null;
</BUG>
try {
<BUG>rmNode = RMUtilities.processHopRMNodeCompsForScheduler(hopRMNodeCompObject,
rmContext);
LOG.debug("HOP :: RMNodeWorker rmNode:" + rmNode);
} catch (IOException ex) {
LOG.error("HOP :: Error retrieving rmNode:" + ex, ex);</BUG>
}

hopRMNodeCompObject
= (RMNodeComps) NdbEventStreamingReceiver.blockingQueue.take();
if (hopRMNodeCompObject != null) {
if (LOG.isDebugEnabled()) {
printHopsRMNodeComps(hopRMNodeCompObject);
}
if (rmContext.isDistributedEnabled()) {
RMNode rmNode = null;
try {
rmNode = RMUtilities.processHopRMNodeCompsForScheduler(
hopRMNodeCompObject,
