You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 小旋锋 <wh...@qq.com> on 2021/02/08 10:14:49 UTC
求问 Yarn application state 和 Flink Job status 的对应关系?
大家好:
Yarn App 有: NEW,NEW_SAVING,SUBMITTED,ACCEPTED,RUNNING,FINISHED,FAILED,KILLED 这些状态,
Flink Job 有: CREATED,RUNNING,FAILING,FAILED,CANCELLING,CANCELED,FINISHED,RESTARTING,SUSPENDED,RECONCILING 这些状态
它们之间的对应关系是怎样的呢? Flink Job的很多中间状态对应 Yarn app 的 RUNNING状态吗?
另1:一般平台检测Flink作业的状态,是通过Yarn Rest API检测 Yarn app state ,还是通过 Flink Rest API检测 Job 的 status呢?
谢谢
祝各位牛年牛牛。