|
大家好:
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呢?
谢谢
祝各位牛年牛牛。
|