|
@@ -498,6 +498,8 @@ public class RMNodeImpl implements RMNode, EventHandler<RMNodeEvent> {
|
|
|
statusEvent.getNodeHealthStatus();
|
|
|
rmNode.setNodeHealthStatus(remoteNodeHealthStatus);
|
|
|
if (!remoteNodeHealthStatus.getIsNodeHealthy()) {
|
|
|
+ LOG.info("Node " + rmNode.nodeId + " reported UNHEALTHY with details: "
|
|
|
+ + remoteNodeHealthStatus.getHealthReport());
|
|
|
rmNode.nodeUpdateQueue.clear();
|
|
|
// Inform the scheduler
|
|
|
rmNode.context.getDispatcher().getEventHandler().handle(
|