Flink on yarn失败任务恢复怎么执行
时间: 2024-01-14 14:02:16 浏览: 265
在Flink on Yarn模式下,当一个任务失败后,Flink会自动尝试重新启动该任务,最多尝试3次。如果任务在3次重试后仍然失败,那么该任务将被视为永久性失败,Flink将不再尝试重新启动该任务。
如果你想要手动重新启动一个失败的任务,可以通过Flink Web Dashboard来进行操作。在Dashboard的“任务管理”页面中,选择需要重新启动的任务,并点击“重新启动”按钮即可。此时,Flink会尝试重新启动该任务并恢复其状态。如果任务仍然无法正常启动,可以尝试手动修复故障并重新启动任务。如果任务状态已经无法恢复,可以考虑重新提交作业并重新运行任务。
相关问题
flink服务的指标 和flink on yarn 中的flink的指标 有哪些相似的地方
Flink服务和Flink on YARN中的Flink指标相似之处包括:
1. Job运行状态指标:包括运行中、已完成、已取消、已失败等状态。
2. Job运行时间指标:包括任务开始时间、任务结束时间、任务运行时长等。
3. Job资源使用指标:包括CPU、内存、网络等资源的使用情况。
4. Task指标:包括Task运行状态、Task运行时间、Task资源使用情况等。
5. 网络指标:包括数据传输速率、网络延迟等。
6. 容错指标:包括重启次数、故障恢复时间等。
以上是相似之处,当然还有一些不同的指标,比如Flink on YARN中会有一些与YARN相关的指标,比如NodeManager的资源使用情况等。
阅读全文