org.springframework.yarn.boot.app.YarnInfoApplication.()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-16 22:15:31 25 4

@Override
protected void runApplication(OptionSet options) throws Exception {
  YarnInfoApplication app = new YarnInfoApplication();
  Properties appProperties = new Properties();
  appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.operation", "PUSHED");
  app.appProperties(appProperties);
  handleApplicationRun(app);
}

@Override
protected void runApplication(OptionSet options) throws Exception {
  YarnInfoApplication app = new YarnInfoApplication();
  Properties appProperties = new Properties();
  appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.operation", "SUBMITTED");
  if (isFlagOn(options, verboseOption)) {
    appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.verbose", "true");
  }
  appProperties.setProperty("spring.yarn.internal.YarnInfoApplication.type", options.valueOf(typeOption));
  app.appProperties(appProperties);
  handleApplicationRun(app);
}

@Override
public Collection<CloudAppInfo> getApplications() {
  ArrayList<CloudAppInfo> infos = new ArrayList<CloudAppInfo>();
  YarnInfoApplication app = new YarnInfoApplication();
  Properties appProperties = new Properties();
  appProperties.setProperty(PREFIX_YIA + "operation", "PUSHED");
  app.appProperties(appProperties);
  String info = runApp(app);
  logger.debug("Full response for PUSHED: {}", info);
  String[] lines = info.split("\\r?\\n");
  if (lines.length > 2) {
    for (int i = 2; i < lines.length; i++) {
      String[] fields = lines[i].trim().split("\\s+");
      if (fields.length > 1) {
        infos.add(new CloudAppInfo(fields[0].trim()));
      }
    }
  }
  return infos;
}

@Override
public Collection<CloudAppInstanceInfo> getInstances() {
  ArrayList<CloudAppInstanceInfo> infos = new ArrayList<CloudAppInstanceInfo>();
  YarnInfoApplication app = new YarnInfoApplication();
  Properties appProperties = new Properties();
  appProperties.setProperty(PREFIX_YIA + "operation", "SUBMITTED");
  appProperties.setProperty(PREFIX_YIA + "verbose", "false");
  appProperties.setProperty(PREFIX_YIA + "type", "DATAFLOW");
  app.appProperties(appProperties);
  String info = runApp(app);
  logger.debug("Full response for SUBMITTED: {}", info);
  String[] lines = info.split("\\r?\\n");
  if (lines.length > 2) {
    for (int i = 2; i < lines.length; i++) {
      String[] fields = lines[i].trim().split("\\s+");
      if (fields.length > 10) {
        infos.add(new CloudAppInstanceInfo(fields[0].trim(), fields[2].trim(), fields[fields.length - 1]
            .trim()));
      }
    }
  }
  return infos;
}

25 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