求问 Yarn application state 和 Flink Job status 的对应关系?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

求问 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呢?


谢谢
祝各位牛年牛牛。