flink的配置文件里,请问yarn.application-attempts 或 yarn.application.start-timeout如何配置,写出示例
时间: 2024-09-10 19:24:40 浏览: 81
在Apache Flink的YARN作业部署配置中,`yarn.application.attempts` 和 `yarn.application.start.timeout` 都是用来设置与YARN交互时的一些重要参数。
`yarn.application.attempts` 控制了Flink作业尝试启动的最大次数。如果作业在指定次数内未能成功提交或运行,Flink将停止尝试并抛出错误。这是一个整数值,例如:
```properties
yarn.application.attempts=5
```
这表示作业最多尝试5次。
`yarn.application.start.timeout` 则指定了作业从提交到开始运行的超时时间(以秒为单位)。如果在这段时间内作业无法启动,Flink会中止任务并回滚。比如设置为300秒:
```properties
yarn.application.start.timeout=300
```
请注意,实际配置时应在`flink-conf.yaml`或`flink-conf.common`文件中找到正确的键路径,它们通常是`yarn.container-launcher-application-attempts`和`yarn.application-startup-timeout`,具体的路径可能会因版本和环境的不同而有所变化。
相关问题
#提交任务 flink run-application -t yarn-application /root/flink060106_util.jar。。。怎么理解。。
这是在使用 Apache Flink 分布式处理框架时提交一个任务的命令,具体解释如下:
`flink run-application`:启动一个 Flink 应用程序。
`-t yarn-application`:指定提交到 YARN 集群上运行。
`/root/flink060106_util.jar`:指定要运行的应用程序 JAR 包路径。
因此,该命令的含义是将 `/root/flink060106_util.jar` 提交到 YARN 集群以运行 Flink 应用程序。
阅读全文