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

Java MoveApplicationAcrossQueuesRequest类代码示例

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

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



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

示例1: testMoveRejectedByScheduler

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;
  
  // Submit application
  Application application = new Application("user1", resourceManager);
  application.submit();

  // Wait for app to be accepted
  RMApp app = resourceManager.rmContext.getRMApps()
          .get(application.getApplicationId());
  while (app.getState() != RMAppState.ACCEPTED) {
    Thread.sleep(100);
  }

  ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    // FIFO scheduler does not support moves
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(
            application.getApplicationId(), "newqueue"));
    fail("Should have hit exception");
  } catch (YarnException ex) {
    assertEquals("Move not supported", ex.getCause().getMessage());
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:27,代码来源:TestMoveApplication.java


示例2: testMoveSuccessful

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test (timeout = 10000)
    public
    void testMoveSuccessful() throws Exception {
  MockRM rm1 = new MockRM(conf);
  rm1.start();
  RMApp app = rm1.submitApp(1024);
  ClientRMService clientRMService = rm1.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService
    .moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest
      .newInstance(app.getApplicationId(), "newqueue"));

  RMApp rmApp = rm1.getRMContext().getRMApps().get(app.getApplicationId());
  assertEquals("newqueue", rmApp.getQueue());
  rm1.stop();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:TestMoveApplication.java


示例3: testMoveRejectedByPermissions

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test
public void testMoveRejectedByPermissions() throws Exception {
  failMove = true;
  
  // Submit application
  final Application application = new Application("user1", resourceManager);
  application.submit();

  final ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    UserGroupInformation.createRemoteUser("otheruser").doAs(
        new PrivilegedExceptionAction<MoveApplicationAcrossQueuesResponse>() {
          @Override
          public MoveApplicationAcrossQueuesResponse run() throws Exception {
            return clientRMService.moveApplicationAcrossQueues(
                MoveApplicationAcrossQueuesRequest.newInstance(
                    application.getApplicationId(), "newqueue"));
          }
          
        });
    fail("Should have hit exception");
  } catch (Exception ex) {
    assertEquals(AccessControlException.class, ex.getCause().getCause().getClass());
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:TestMoveApplication.java


示例4: testMoveRejectedByScheduler

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test
public void testMoveRejectedByScheduler() throws Exception {
  failMove = true;
  
  // Submit application
  Application application = new Application("user1", resourceManager);
  application.submit();

  ClientRMService clientRMService = resourceManager.getClientRMService();
  try {
    // FIFO scheduler does not support moves
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(
            application.getApplicationId(), "newqueue"));
    fail("Should have hit exception");
  } catch (YarnException ex) {
    assertEquals("Move not supported", ex.getCause().getMessage());
  }
}
 
开发者ID:Seagate,项目名称:hadoop-on-lustre2,代码行数:20,代码来源:TestMoveApplication.java


示例5: testMoveSuccessful

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test (timeout = 5000)
public void testMoveSuccessful() throws Exception {
  // Submit application
  Application application = new Application("user1", resourceManager);
  ApplicationId appId = application.getApplicationId();
  application.submit();
  
  // Wait for app to be accepted
  RMApp app = resourceManager.rmContext.getRMApps().get(appId);
  while (app.getState() != RMAppState.ACCEPTED) {
    Thread.sleep(100);
  }

  ClientRMService clientRMService = resourceManager.getClientRMService();
  // FIFO scheduler does not support moves
  clientRMService.moveApplicationAcrossQueues(
      MoveApplicationAcrossQueuesRequest.newInstance(appId, "newqueue"));
  
  RMApp rmApp = resourceManager.getRMContext().getRMApps().get(appId);
  assertEquals("newqueue", rmApp.getQueue());
}
 
开发者ID:Seagate,项目名称:hadoop-on-lustre2,代码行数:22,代码来源:TestMoveApplication.java


示例6: moveApplicationAcrossQueues

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailOver());

  return Records.newRecord(MoveApplicationAcrossQueuesResponse.class);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:11,代码来源:ProtocolHATestBase.java


示例7: moveApplicationAcrossQueues

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,
    IOException {
  MoveApplicationAcrossQueuesRequestProto requestProto =
      ((MoveApplicationAcrossQueuesRequestPBImpl) request).getProto();
  try {
    return new MoveApplicationAcrossQueuesResponsePBImpl(
        proxy.moveApplicationAcrossQueues(null, requestProto));

  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:16,代码来源:ApplicationClientProtocolPBClientImpl.java


示例8: testMoveTooLate

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test (timeout = 10000)
public void testMoveTooLate() throws Exception {
  // Submit application
  Application application = new Application("user1", resourceManager);
  ApplicationId appId = application.getApplicationId();
  application.submit();
  
  ClientRMService clientRMService = resourceManager.getClientRMService();
  // Kill the application
  clientRMService.forceKillApplication(
      KillApplicationRequest.newInstance(appId));
  RMApp rmApp = resourceManager.getRMContext().getRMApps().get(appId);
  // wait until it's dead
  while (rmApp.getState() != RMAppState.KILLED) {
    Thread.sleep(100);
  }
  
  try {
    clientRMService.moveApplicationAcrossQueues(
        MoveApplicationAcrossQueuesRequest.newInstance(appId, "newqueue"));
    fail("Should have hit exception");
  } catch (YarnException ex) {
    assertEquals(YarnException.class,
        ex.getClass());
    assertEquals("App in KILLED state cannot be moved.", ex.getMessage());
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:28,代码来源:TestMoveApplication.java


示例9: testMoveAbsentApplication

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Test (expected = ApplicationNotFoundException.class)
public void testMoveAbsentApplication() throws YarnException {
  RMContext rmContext = mock(RMContext.class);
  when(rmContext.getRMApps()).thenReturn(
      new ConcurrentHashMap<ApplicationId, RMApp>());
  ClientRMService rmService = new ClientRMService(rmContext, null, null,
      null, null, null);
  ApplicationId applicationId =
      BuilderUtils.newApplicationId(System.currentTimeMillis(), 0);
  MoveApplicationAcrossQueuesRequest request =
      MoveApplicationAcrossQueuesRequest.newInstance(applicationId, "newqueue");
  rmService.moveApplicationAcrossQueues(request);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:TestClientRMService.java


示例10: moveApplicationAcrossQueues

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Override
public void moveApplicationAcrossQueues(ApplicationId appId,
    String queue) throws YarnException, IOException {
  MoveApplicationAcrossQueuesRequest request =
      MoveApplicationAcrossQueuesRequest.newInstance(appId, queue);
  rmClient.moveApplicationAcrossQueues(request);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:8,代码来源:YarnClientImpl.java


示例11: moveApplicationAcrossQueues

import org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest; //导入依赖的package包/类
@Override
public MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(
    MoveApplicationAcrossQueuesRequest request) throws YarnException,
    IOException {
  return RecordFactoryProvider.getRecordFactory(null).newRecordInstance(
      MoveApplicationAcrossQueuesResponse.class);
}
 
开发者ID:intel-hpdd,项目名称:scheduling-connector-for-hadoop,代码行数:8,代码来源:HPCApplicationClientProtocolImpl.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java AdapterInputConnectionFactory类代码示例发布时间:2022-05-22
下一篇:
Java PlayerEatFoodEvent类代码示例发布时间: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