• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java WebServicesTestUtils类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.yarn.webapp.WebServicesTestUtils的典型用法代码示例。如果您正苦于以下问题:Java WebServicesTestUtils类的具体用法?Java WebServicesTestUtils怎么用?Java WebServicesTestUtils使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



WebServicesTestUtils类属于org.apache.hadoop.yarn.webapp包,在下文中一共展示了WebServicesTestUtils类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: verifyNodeAppInfoXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyNodeAppInfoXML(NodeList nodes, Application app,
    HashMap<String, String> hash) throws JSONException, Exception {
  for (int i = 0; i < nodes.getLength(); i++) {
    Element element = (Element) nodes.item(i);

    verifyNodeAppInfoGeneric(app,
        WebServicesTestUtils.getXmlString(element, "id"),
        WebServicesTestUtils.getXmlString(element, "state"),
        WebServicesTestUtils.getXmlString(element, "user"));

    NodeList ids = element.getElementsByTagName("containerids");
    for (int j = 0; j < ids.getLength(); j++) {
      Element line = (Element) ids.item(j);
      Node first = line.getFirstChild();
      String val = first.getNodeValue();
      assertEquals("extra containerid: " + val, val, hash.remove(val));
    }
    assertTrue("missing containerids", hash.isEmpty());
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestNMWebServicesApps.java


示例2: testJobsQueryStartTimeEndInvalidformat

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testJobsQueryStartTimeEndInvalidformat() throws JSONException,
    Exception {
  WebResource r = resource();
  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs").queryParam("startedTimeEnd", "efsd")
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);
  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils
      .checkStringMatch(
          "exception message",
          "java.lang.Exception: Invalid number format: For input string: \"efsd\"",
          message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "BadRequestException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:TestHsWebServicesJobsQuery.java


示例3: verifyHSInfoXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyHSInfoXML(String xml, AppContext ctx)
    throws JSONException, Exception {
  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
  DocumentBuilder db = dbf.newDocumentBuilder();
  InputSource is = new InputSource();
  is.setCharacterStream(new StringReader(xml));
  Document dom = db.parse(is);
  NodeList nodes = dom.getElementsByTagName("historyInfo");
  assertEquals("incorrect number of elements", 1, nodes.getLength());

  for (int i = 0; i < nodes.getLength(); i++) {
    Element element = (Element) nodes.item(i);
    verifyHsInfoGeneric(
        WebServicesTestUtils.getXmlString(element, "hadoopVersionBuiltOn"),
        WebServicesTestUtils.getXmlString(element, "hadoopBuildVersion"),
        WebServicesTestUtils.getXmlString(element, "hadoopVersion"),
        WebServicesTestUtils.getXmlLong(element, "startedOn"));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:20,代码来源:TestHsWebServices.java


示例4: testJobsQueryLimitInvalid

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testJobsQueryLimitInvalid() throws JSONException, Exception {
  WebResource r = resource();

  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs").queryParam("limit", "-1")
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);

  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils.checkStringMatch("exception message",
      "java.lang.Exception: limit value must be greater then 0", message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "BadRequestException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:24,代码来源:TestHsWebServicesJobsQuery.java


示例5: verifyContainersInfoXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyContainersInfoXML(NodeList nodes, Container cont)
    throws JSONException, Exception {
  for (int i = 0; i < nodes.getLength(); i++) {
    Element element = (Element) nodes.item(i);

    verifyNodeContainerInfoGeneric(cont,
        WebServicesTestUtils.getXmlString(element, "id"),
        WebServicesTestUtils.getXmlString(element, "state"),
        WebServicesTestUtils.getXmlString(element, "user"),
        WebServicesTestUtils.getXmlInt(element, "exitCode"),
        WebServicesTestUtils.getXmlString(element, "diagnostics"),
        WebServicesTestUtils.getXmlString(element, "nodeId"),
        WebServicesTestUtils.getXmlInt(element, "totalMemoryNeededMB"),
        WebServicesTestUtils.getXmlInt(element, "totalVCoresNeeded"),
        WebServicesTestUtils.getXmlString(element, "containerLogsLink"));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:18,代码来源:TestNMWebServicesContainers.java


示例6: testInvalidUri

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testInvalidUri() throws JSONException, Exception {
  WebResource r = resource();
  String responseStr = "";
  try {
    responseStr = r.path("ws").path("v1").path("cluster").path("bogus")
        .accept(MediaType.APPLICATION_JSON).get(String.class);
    fail("should have thrown exception on invalid uri");
  } catch (UniformInterfaceException ue) {
    ClientResponse response = ue.getResponse();
    assertEquals(Status.NOT_FOUND, response.getClientResponseStatus());

    WebServicesTestUtils.checkStringMatch(
        "error string exists and shouldn't", "", responseStr);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:TestRMWebServices.java


示例7: testInvalidAccept

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testInvalidAccept() throws JSONException, Exception {
  WebResource r = resource();
  String responseStr = "";
  try {
    responseStr = r.path("ws").path("v1").path("cluster")
        .accept(MediaType.TEXT_PLAIN).get(String.class);
    fail("should have thrown exception on invalid uri");
  } catch (UniformInterfaceException ue) {
    ClientResponse response = ue.getResponse();
    assertEquals(Status.INTERNAL_SERVER_ERROR,
        response.getClientResponseStatus());
    WebServicesTestUtils.checkStringMatch(
        "error string exists and shouldn't", "", responseStr);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:TestRMWebServices.java


示例8: testJobsQueryFinishTimeInvalidformat

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testJobsQueryFinishTimeInvalidformat() throws JSONException,
    Exception {
  WebResource r = resource();
  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs").queryParam("finishedTimeBegin", "efsd")
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);
  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils
      .checkStringMatch(
          "exception message",
          "java.lang.Exception: Invalid number format: For input string: \"efsd\"",
          message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "BadRequestException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:TestHsWebServicesJobsQuery.java


示例9: verifyNodesXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyNodesXML(NodeList nodes, MockNM nm) throws JSONException,
    Exception {
  for (int i = 0; i < nodes.getLength(); i++) {
    Element element = (Element) nodes.item(i);
    verifyNodeInfoGeneric(nm,
        WebServicesTestUtils.getXmlString(element, "state"),
        WebServicesTestUtils.getXmlString(element, "rack"),
        WebServicesTestUtils.getXmlString(element, "id"),
        WebServicesTestUtils.getXmlString(element, "nodeHostName"),
        WebServicesTestUtils.getXmlString(element, "nodeHTTPAddress"),
        WebServicesTestUtils.getXmlLong(element, "lastHealthUpdate"),
        WebServicesTestUtils.getXmlString(element, "healthReport"),
        WebServicesTestUtils.getXmlInt(element, "numContainers"),
        WebServicesTestUtils.getXmlLong(element, "usedMemoryMB"),
        WebServicesTestUtils.getXmlLong(element, "availMemoryMB"),
        WebServicesTestUtils.getXmlLong(element, "usedVirtualCores"),
        WebServicesTestUtils.getXmlLong(element,  "availableVirtualCores"),
        WebServicesTestUtils.getXmlLong(element, "usedGpuCores"),
        WebServicesTestUtils.getXmlLong(element, "availableGpuCores"),
        WebServicesTestUtils.getXmlString(element, "version"));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:23,代码来源:TestRMWebServicesNodes.java


示例10: verifyHsJobTaskCounters

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyHsJobTaskCounters(JSONObject info, Task task)
    throws JSONException {

  assertEquals("incorrect number of elements", 2, info.length());

  WebServicesTestUtils.checkStringMatch("id", MRApps.toString(task.getID()),
      info.getString("id"));
  // just do simple verification of fields - not data is correct
  // in the fields
  JSONArray counterGroups = info.getJSONArray("taskCounterGroup");
  for (int i = 0; i < counterGroups.length(); i++) {
    JSONObject counterGroup = counterGroups.getJSONObject(i);
    String name = counterGroup.getString("counterGroupName");
    assertTrue("name not set", (name != null && !name.isEmpty()));
    JSONArray counters = counterGroup.getJSONArray("counter");
    for (int j = 0; j < counters.length(); j++) {
      JSONObject counter = counters.getJSONObject(j);
      String counterName = counter.getString("name");
      assertTrue("name not set",
          (counterName != null && !counterName.isEmpty()));
      long value = counter.getLong("value");
      assertTrue("value  >= 0", value >= 0);
    }
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:TestHsWebServicesTasks.java


示例11: validateGetNewApplicationXMLResponse

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
protected String validateGetNewApplicationXMLResponse(String response)
    throws ParserConfigurationException, IOException, SAXException {
  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
  DocumentBuilder db = dbf.newDocumentBuilder();
  InputSource is = new InputSource();
  is.setCharacterStream(new StringReader(response));
  Document dom = db.parse(is);
  NodeList nodes = dom.getElementsByTagName("NewApplication");
  assertEquals("incorrect number of elements", 1, nodes.getLength());
  Element element = (Element) nodes.item(0);
  String appId = WebServicesTestUtils.getXmlString(element, "application-id");
  assertTrue(!appId.isEmpty());
  NodeList maxResourceNodes =
      element.getElementsByTagName("maximum-resource-capability");
  assertEquals(1, maxResourceNodes.getLength());
  Element maxResourceCapability = (Element) maxResourceNodes.item(0);
  long memory =
      WebServicesTestUtils.getXmlLong(maxResourceCapability, "memory");
  long vCores =
      WebServicesTestUtils.getXmlLong(maxResourceCapability, "vCores");
  assertTrue(memory != 0);
  assertTrue(vCores != 0);
  return appId;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:25,代码来源:TestRMWebServicesAppsModification.java


示例12: getDelegationTokenFromXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public static DelegationToken getDelegationTokenFromXML(String tokenXML)
    throws IOException, ParserConfigurationException, SAXException {
  DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
  DocumentBuilder db = dbf.newDocumentBuilder();
  InputSource is = new InputSource();
  is.setCharacterStream(new StringReader(tokenXML));
  Document dom = db.parse(is);
  NodeList nodes = dom.getElementsByTagName("delegation-token");
  assertEquals("incorrect number of elements", 1, nodes.getLength());
  Element element = (Element) nodes.item(0);
  DelegationToken ret = new DelegationToken();
  String token = WebServicesTestUtils.getXmlString(element, "token");
  if (token != null) {
    ret.setToken(token);
  } else {
    long expiration =
        WebServicesTestUtils.getXmlLong(element, "expiration-time");
    ret.setNextExpirationTime(expiration);
  }
  return ret;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:22,代码来源:TestRMWebServicesDelegationTokens.java


示例13: verifyTaskGeneric

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyTaskGeneric(Task task, String id, String state,
    String type, String successfulAttempt, long startTime, long finishTime,
    long elapsedTime, float progress) {

  TaskId taskid = task.getID();
  String tid = MRApps.toString(taskid);
  TaskReport report = task.getReport();

  WebServicesTestUtils.checkStringMatch("id", tid, id);
  WebServicesTestUtils.checkStringMatch("type", task.getType().toString(),
      type);
  WebServicesTestUtils.checkStringMatch("state", report.getTaskState()
      .toString(), state);
  // not easily checked without duplicating logic, just make sure its here
  assertNotNull("successfulAttempt null", successfulAttempt);
  assertEquals("startTime wrong", report.getStartTime(), startTime);
  assertEquals("finishTime wrong", report.getFinishTime(), finishTime);
  assertEquals("elapsedTime wrong", finishTime - startTime, elapsedTime);
  assertEquals("progress wrong", report.getProgress() * 100, progress, 1e-3f);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestHsWebServicesTasks.java


示例14: verifyAppAttemptsXML

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyAppAttemptsXML(NodeList nodes, RMAppAttempt appAttempt,
    String user)
    throws JSONException, Exception {

  for (int i = 0; i < nodes.getLength(); i++) {
    Element element = (Element) nodes.item(i);

    verifyAppAttemptInfoGeneric(appAttempt,
        WebServicesTestUtils.getXmlInt(element, "id"),
        WebServicesTestUtils.getXmlLong(element, "startTime"),
        WebServicesTestUtils.getXmlString(element, "containerId"),
        WebServicesTestUtils.getXmlString(element, "nodeHttpAddress"),
        WebServicesTestUtils.getXmlString(element, "nodeId"),
        WebServicesTestUtils.getXmlString(element, "logsLink"), user);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:TestRMWebServicesApps.java


示例15: verifyAppAttemptInfoGeneric

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyAppAttemptInfoGeneric(RMAppAttempt appAttempt, int id,
    long startTime, String containerId, String nodeHttpAddress, String nodeId,
    String logsLink, String user)
        throws JSONException, Exception {

  assertEquals("id doesn't match", appAttempt.getAppAttemptId()
      .getAttemptId(), id);
  assertEquals("startedTime doesn't match", appAttempt.getStartTime(),
      startTime);
  WebServicesTestUtils.checkStringMatch("containerId", appAttempt
      .getMasterContainer().getId().toString(), containerId);
  WebServicesTestUtils.checkStringMatch("nodeHttpAddress", appAttempt
      .getMasterContainer().getNodeHttpAddress(), nodeHttpAddress);
  WebServicesTestUtils.checkStringMatch("nodeId", appAttempt
      .getMasterContainer().getNodeId().toString(), nodeId);
  assertTrue("logsLink doesn't match", logsLink.startsWith("//"));
  assertTrue(
      "logsLink doesn't contain user info", logsLink.endsWith("/"
      + user));
}
 
开发者ID:naver,项目名称:hadoop,代码行数:21,代码来源:TestRMWebServicesApps.java


示例16: testInvalidUri

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testInvalidUri() throws JSONException, Exception {
  WebResource r = resource();
  String responseStr = "";
  try {
    responseStr =
        r.path("ws").path("v1").path("applicationhistory").path("bogus")
          .queryParam("user.name", USERS[round])
          .accept(MediaType.APPLICATION_JSON).get(String.class);
    fail("should have thrown exception on invalid uri");
  } catch (UniformInterfaceException ue) {
    ClientResponse response = ue.getResponse();
    assertEquals(Status.NOT_FOUND, response.getClientResponseStatus());

    WebServicesTestUtils.checkStringMatch(
      "error string exists and shouldn't", "", responseStr);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:19,代码来源:TestAHSWebServices.java


示例17: testInvalidAccept

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testInvalidAccept() throws JSONException, Exception {
  WebResource r = resource();
  String responseStr = "";
  try {
    responseStr =
        r.path("ws").path("v1").path("applicationhistory")
          .queryParam("user.name", USERS[round])
          .accept(MediaType.TEXT_PLAIN).get(String.class);
    fail("should have thrown exception on invalid uri");
  } catch (UniformInterfaceException ue) {
    ClientResponse response = ue.getResponse();
    assertEquals(Status.INTERNAL_SERVER_ERROR,
      response.getClientResponseStatus());
    WebServicesTestUtils.checkStringMatch(
      "error string exists and shouldn't", "", responseStr);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:19,代码来源:TestAHSWebServices.java


示例18: testJobsQueryStartTimeInvalidformat

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testJobsQueryStartTimeInvalidformat() throws JSONException,
    Exception {
  WebResource r = resource();
  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs").queryParam("startedTimeBegin", "efsd")
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);
  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils
      .checkStringMatch(
          "exception message",
          "java.lang.Exception: Invalid number format: For input string: \"efsd\"",
          message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "BadRequestException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "org.apache.hadoop.yarn.webapp.BadRequestException", classname);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:TestHsWebServicesJobsQuery.java


示例19: verifyTaskGeneric

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
public void verifyTaskGeneric(Task task, String id, String state,
    String type, String successfulAttempt, long startTime, long finishTime,
    long elapsedTime, float progress, String status) {

  TaskId taskid = task.getID();
  String tid = MRApps.toString(taskid);
  TaskReport report = task.getReport();

  WebServicesTestUtils.checkStringMatch("id", tid, id);
  WebServicesTestUtils.checkStringMatch("type", task.getType().toString(),
      type);
  WebServicesTestUtils.checkStringMatch("state", report.getTaskState()
      .toString(), state);
  // not easily checked without duplicating logic, just make sure its here
  assertNotNull("successfulAttempt null", successfulAttempt);
  assertEquals("startTime wrong", report.getStartTime(), startTime);
  assertEquals("finishTime wrong", report.getFinishTime(), finishTime);
  assertEquals("elapsedTime wrong", finishTime - startTime, elapsedTime);
  assertEquals("progress wrong", report.getProgress() * 100, progress, 1e-3f);
  assertEquals("status wrong", report.getStatus(), status);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:22,代码来源:TestAMWebServicesTasks.java


示例20: testJobsQueryStateInvalid

import org.apache.hadoop.yarn.webapp.WebServicesTestUtils; //导入依赖的package包/类
@Test
public void testJobsQueryStateInvalid() throws JSONException, Exception {
  WebResource r = resource();

  ClientResponse response = r.path("ws").path("v1").path("history")
      .path("mapreduce").path("jobs").queryParam("state", "InvalidState")
      .accept(MediaType.APPLICATION_JSON).get(ClientResponse.class);

  assertEquals(Status.BAD_REQUEST, response.getClientResponseStatus());
  assertEquals(MediaType.APPLICATION_JSON_TYPE, response.getType());
  JSONObject msg = response.getEntity(JSONObject.class);
  JSONObject exception = msg.getJSONObject("RemoteException");
  assertEquals("incorrect number of elements", 3, exception.length());
  String message = exception.getString("message");
  String type = exception.getString("exception");
  String classname = exception.getString("javaClassName");
  WebServicesTestUtils
      .checkStringContains(
          "exception message",
          "org.apache.hadoop.mapreduce.v2.api.records.JobState.InvalidState",
          message);
  WebServicesTestUtils.checkStringMatch("exception type",
      "IllegalArgumentException", type);
  WebServicesTestUtils.checkStringMatch("exception classname",
      "java.lang.IllegalArgumentException", classname);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:27,代码来源:TestHsWebServicesJobsQuery.java



注:本文中的org.apache.hadoop.yarn.webapp.WebServicesTestUtils类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Id类代码示例发布时间:2022-05-22
下一篇:
Java RetryUntilElapsed类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap