|
@@ -766,6 +766,7 @@ public class TestHsWebServicesJobs extends JerseyTest {
|
|
|
for (int i = 0; i < attempts.length(); i++) {
|
|
|
JSONObject attempt = attempts.getJSONObject(i);
|
|
|
verifyHsJobAttemptsGeneric(job, attempt.getString("nodeHttpAddress"),
|
|
|
+ attempt.getString("nodeId"),
|
|
|
attempt.getInt("id"),
|
|
|
attempt.getLong("startTime"), attempt.getString("containerId"),
|
|
|
attempt.getString("logsLink"));
|
|
@@ -779,6 +780,7 @@ public class TestHsWebServicesJobs extends JerseyTest {
|
|
|
Element element = (Element) nodes.item(i);
|
|
|
verifyHsJobAttemptsGeneric(job,
|
|
|
WebServicesTestUtils.getXmlString(element, "nodeHttpAddress"),
|
|
|
+ WebServicesTestUtils.getXmlString(element, "nodeId"),
|
|
|
WebServicesTestUtils.getXmlInt(element, "id"),
|
|
|
WebServicesTestUtils.getXmlLong(element, "startTime"),
|
|
|
WebServicesTestUtils.getXmlString(element, "containerId"),
|
|
@@ -787,7 +789,8 @@ public class TestHsWebServicesJobs extends JerseyTest {
|
|
|
}
|
|
|
|
|
|
public void verifyHsJobAttemptsGeneric(Job job, String nodeHttpAddress,
|
|
|
- int id, long startTime, String containerId, String logsLink) {
|
|
|
+ String nodeId, int id, long startTime, String containerId,
|
|
|
+ String logsLink) {
|
|
|
boolean attemptFound = false;
|
|
|
for (AMInfo amInfo : job.getAMInfos()) {
|
|
|
if (amInfo.getAppAttemptId().getAttemptId() == id) {
|
|
@@ -801,10 +804,9 @@ public class TestHsWebServicesJobs extends JerseyTest {
|
|
|
WebServicesTestUtils.checkStringMatch("containerId", amInfo
|
|
|
.getContainerId().toString(), containerId);
|
|
|
|
|
|
- String localLogsLink = join(
|
|
|
- "hsmockwebapp",
|
|
|
- ujoin("logs", nodeHttpAddress, containerId,
|
|
|
- MRApps.toString(job.getID()), job.getUserName()));
|
|
|
+ String localLogsLink = join("hsmockwebapp",
|
|
|
+ ujoin("logs", nodeId, containerId, MRApps.toString(job.getID()),
|
|
|
+ job.getUserName()));
|
|
|
|
|
|
assertTrue("logsLink", logsLink.contains(localLogsLink));
|
|
|
}
|