diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/TestResourceTrackerOnHA.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/TestResourceTrackerOnHA.java index 8885769..70d51a2 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/TestResourceTrackerOnHA.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/TestResourceTrackerOnHA.java @@ -54,7 +54,7 @@ public void shutDown() { @Test(timeout = 15000) public void testResourceTrackerOnHA() throws Exception { - NodeId nodeId = NodeId.newInstance("localhost", 0); + NodeId nodeId = NodeId.newInstance("localhost", 1); Resource resource = Resource.newInstance(2048, 4); // make sure registerNodeManager works when failover happens @@ -66,9 +66,7 @@ public void testResourceTrackerOnHA() throws Exception { // restart the failover thread, and make sure nodeHeartbeat works failoverThread = createAndStartFailoverThread(); - NodeStatus status = - NodeStatus.newInstance(NodeId.newInstance("localhost", 0), 0, null, - null, null); + NodeStatus status = NodeStatus.newInstance(nodeId, 0, null, null, null); NodeHeartbeatRequest request2 = NodeHeartbeatRequest.newInstance(status, null, null); resourceTracker.nodeHeartbeat(request2);