org.springframework.yarn.test.support.YarnClusterFactoryBean.setNodes()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-19 22:09:31 26 4

/**
 * Gets and starts the mini cluster.
 *
 * @param clusterInfo the info about the cluster
 * @return the running mini cluster
 */
public YarnCluster getCluster(ClusterInfo clusterInfo) {
  YarnCluster cluster = clusters.get(clusterInfo);
  if (cluster == null) {
    log.info("Building new cluster for ClusterInfo=" + clusterInfo);
    try {
      YarnClusterFactoryBean fb = new YarnClusterFactoryBean();
      fb.setClusterId("yarn-" + clusterInfo.hashCode());
      fb.setNodes(clusterInfo.getNumYarn());
      fb.setAutoStart(true);
      fb.afterPropertiesSet();
      cluster = fb.getObject();
      clusters.put(clusterInfo, cluster);
    } catch (Exception e) {
    }
  } else {
    log.info("Found cached cluster for ClusterInfo=" + clusterInfo);
  }
  return cluster;
}

/**
 * Gets and starts the mini cluster.
 *
 * @param clusterInfo the info about the cluster
 * @return the running mini cluster
 */
public YarnCluster getCluster(ClusterInfo clusterInfo) {
  YarnCluster cluster = clusters.get(clusterInfo);
  if (cluster == null) {
    log.info("Building new cluster for ClusterInfo=" + clusterInfo);
    try {
      YarnClusterFactoryBean fb = new YarnClusterFactoryBean();
      fb.setClusterId("yarn-" + clusterInfo.hashCode());
      fb.setNodes(clusterInfo.getNumYarn());
      fb.setAutoStart(true);
      fb.afterPropertiesSet();
      cluster = fb.getObject();
      clusters.put(clusterInfo, cluster);
    } catch (Exception e) {
    }
  } else {
    log.info("Found cached cluster for ClusterInfo=" + clusterInfo);
  }
  return cluster;
}

26 4 0

• java - java:软件包org.springframework.dao和org.springframework.jdbc.core不存在

  刚开始处理Maven和Spring。当我尝试创建DAO和ResultSet然后运行应用程序时，抛出errors: Error:(4, 31) java: package org.springframe

• java - 为什么我的项目找不到 org.springframework.test 或 org.springframework.boot.test？

  问题: Error:(15, 10) java: cannot find symbol symbol: class SpringRunner Error:(16, 2) java: cannot

• spring - 为什么 org.springframework.boot 导入不起作用，但 org.springframework.web 却起作用？

  我正在尝试构建这个 RESTful 服务示例:https://spring.io/guides/gs/rest-service/GreetingController.java 的导入没有错误: pac

• java - org.springframework.beans.factory.BeanCreationException & org.springframework.beans.BeanInstantiationException,未找到默认构造函数

  如果我尝试向构造函数注入(inject) Facebook 参数，我将尝试使用 facebook api 使用 spring + thymeleaf + hibernate 创建 Facebook 应

• java - org.springframework.beans.factory.UnsatisfiedDependencyException org.springframework.beans.factory.NoUniqueBeanDefinitionException

  如何解决Spring中Bean的自动连接歧义？我们有一个 Dessert 接口(interface)，并且有实现该接口(interface)(Dessert)的三种不同的甜点(Bean)。 今天的甜点

• java - 缺少 Artifact org.springframework :spring-context:jar:${org. springframework-version}

  请问为什么我的 pom.xml 文件中会出现此错误 Missing artifact org.springframework:spring-context:jar:${org.springframew

• java - 在哪里可以找到 org.springframework.cassandra.config jar。我看到的只是 org.springframework.data.cassandra

  让 gradle 构建正常工作( from a previous question related to this one )，安迪·威尔金森(Andy Wilkinson)为我回答，没有问题。正在为

• java - 错误: org. springframework.web.context.ContextLoader - 上下文初始化失败org.springframework.beans.factory.BeanCreationException

  我正在 tomcat 7 中开发网站(spring 3.1.1)，但出现错误 ERROR: org.springframework.web.context.ContextLoader - Contex

• java - 已解决 [org.springframework.validation.BindException : org. springframework.validation.BeanPropertyBindingResult: 2 个错误

  我在将航类信息保存到 mysql 数据库时遇到错误。请帮助我下面是我的代码: 我已经尝试了所有方法，添加模式和这么多 它不会从字符串转换为日期 控制台日志 2020-05-12 13:19:21.04

• java - 没有下载 org.springframework :org. springframework.core :3. 2.2.RELEASE 的文件

  我使用intellij创建了一个小型java应用程序，后来我使用“添加框架支持”选项将该项目更新为Maven项目。当我厌倦了在项目上添加 spring jar 文件时，出现以下错误:“没有为 org.

• java - 尝试从类 org.springframework.data.mapping.PropertyReferenceException 访问类 org.springframework.beans.PropertyMatches

  我尝试使用 org.springframework.data.mongodb.core.MongoOperations 从 mongo 集合中查询记录。我在 CompanyTemplRepoImpl

• java - org.springframework.orm.jpa.EntityManagerHolder 无法转换为 org.springframework.orm.hibernate5.SessionHolder

  我尝试将 Spring4 与 Hibernate5 一起使用，但出现此错误: org.springframework.orm.jpa.EntityManagerHolder cannot be cas

• java.lang.NoClassDefFoundError : org/springframework/web/servlet/HttpServletBean : org/springframework/context/EnvironmentAware

  我是这个论坛的新手。我正在尝试使用 spring 3.2.6 和 tomcat 7.0 制作一个应用程序。我已将所有必需的 jar 添加到 WEB-INF/lib 文件夹中。 DispatcherSe

• java - 异常: org. springframework.beans.factory.BeanCreationException:创建名称为 'org.springframework.security.filterChains'的bean时出错

  我在 maven 架构中使用 Spring 框架 4.0.1.RELEASE、OAuth Security 2.0.7.RELEASE，当我编译代码时，出现以下错误。 SEVERE: Exceptio

• java - org.springframework.web.bind.annotation.ResponseStatus 和 org.springframework.http.HttpStatus 不存在

  我正在使用以下指令开发 CRUD Web 应用程序: https://www.javaguides.net/2019/02/spring-boot-2-angular-7-crud-example-t

• java - org/springframework/web/servlet/ModelAndView 类和 org/springframework/web/portlet/ModelAndView 之间的区别

  这个问题已经有答案了: what is the difference in org.springframework.web.servlet.ModelAndView vs org.springfram

• java - 我收到此错误 org.springframework.orm.jpa.EntityManagerHolder 无法转换为 org.springframework.orm.hibernate5.SessionHolder

  我正在尝试将 hibernate 与 spring boot 一起使用。但我收到此错误:org.springframework.orm.jpa.EntityManagerHolder 无法转换为 or

• java - ClassCastException : org. springframework.orm.jpa.EntityManagerHolder 无法转换为 org.springframework.orm.hibernate5.SessionHolder

  我尝试创建简单的用户登录和注册页面。但我无法使用服务方法创建用户。我有创建新用户的服务。 @Service public class LocalUserDetailsService implement

• spring - org.springframework.beans.factory.BeanCreationException : Error creating bean with name 'org.springframework.security.filterChains'

  我用 STS、Roo 和 GWT 创建了一个新项目，并尝试包含 Spring Security。 从那时起，我收到以下错误。有没有人知道出了什么问题？! org.springframework.bea

• spring - org/springframework/core/NativeDetector java.lang.NoClassDefFoundError : org/springframework/core/NativeDetector issue is comming

  这些是我正在使用的版本和依赖项 我怀疑版本需要更改但更改为什么，我不确定 springCore : '5.3.3', springjdbc