調用DescribeFlowNodeInstance接口，查詢節點實例（工作流節點實例和作業運行節點實例）詳情。

調試

您可以在OpenAPI Explorer中直接運行該接口，免去您計算簽名的困擾。運行成功后，OpenAPI Explorer可以自動生成SDK代碼示例。

請求參數

名稱 類型 是否必選 示例值 描述
Action String 是 DescribeFlowNodeInstance

系統規定參數。取值：DescribeFlowNodeInstance。

ProjectId String 是 FP-7A1018ADE917****

項目ID
Id String 是 FNI-FE4BD156E939****

節點實例ID。
RegionId String 是 cn-hangzhou

地域ID。

返回數據

名稱 類型 示例值 描述
Status String OK

實例的執行狀態，取值如下：

  • PREP（等待啟動）
  • SUBMITTING（提交中）
  • RUNNING（運行中）
  • DONE（已完成）
  • OK（執行成功）
  • FAILED（執行失敗）
  • KILLED（已終止）
  • KILL_FAILED（終止失敗）
  • START_RETRY（開始重試）
Type String JOB

節點類型，取值如下：

  • JOB：作業
  • CLUSTER：集群
  • START：開始
  • END：結束
EnvConf String {"key":"value"}

環境變量。
ProjectId String FP-7A1018ADE917****

項目ID。
RetryInterval String 15

重試間隔，單位s。
JobType String HIVE_SQL

作業類型。
Mode String YARN

模型模式。支持：YARN和LOCAL YARN。將作業包裝成一個 launcher提交至YARN中執行LOCAL。作業直接在主機上以進程方式運行。
ExternalInfo String empty

外部信息。例如運行作業的錯誤診斷信息。
GmtModified Long 1540796247000

修改時間。
ExternalChildIds String application_1541559535023_34028

任務的application列表。
MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]}

監控配置，只有SPARK_STREAMING類型作業支持。
ExternalStatus String SUCCESS

實例對應的Container的狀態，取值如下：

  • SUBMITTED（已提交）
  • RUNNING（運行中）
  • SUCCESS（執行成功）
  • FAIL（執行失敗）
  • KILL_FAIL（終止失敗）
  • KILL_SUCCESS（終止成功）
RequestId String 1549175a-6d14-4c8a-89f9-5e28300f6d7e

請求ID。
JobName String myJob

作業名稱。
RetryPolicy String 無

重試策略。
Adhoc Boolean true

是否臨時查詢。
ExternalId String application_1541559535023_34027

啟動器的application的ID。
Pending Boolean true

是否結束。
ClusterId String C-F32FB31D8295****

集群ID。
MaxRetry String 0

最大重試次數。
FailAct String STOP

失敗策略，取值如下：

  • STOP（終止工作流）
  • CONTINUE（跳過）
JobParams String ls -l

作業內容。
FlowInstanceId String FI-7CAF9709CD32****

工作流實例ID。
ParamConf String {"date":"${yyyy-MM-dd}"}

參數配置。
HostName String emr-header-1.cluster-12345

節點實例運行所在主機的名稱。您可以登錄主機使用hostname命令查看主機名稱。
FlowId String F-35683D0E4573****

工作流ID。
Retries Integer 0

重試次數。
EndTime Long 1540796248000

運行結束時間。
StartTime Long 1540796237000

運行開始時間。
RunConf String {"priority":1,"userName":"hadoop","memory":2048,"cores":1}

運行配置，取值如下：

  • priority：優先級。
  • userName：用于提交作業Linux用戶。
  • memory：內存單位為MB。
  • cores： 核數。
ExternalSubId String container_1541559535023_34027_01_000001

啟動器container的ID。
NodeName String 812589f5

節點名稱。
JobId String FJ-A23BD131A862****

作業ID。
ClusterName String myCluster

集群名稱。
GmtCreate Long 1540796236000

創建時間。
Duration Long 600

運行持續時間。
Id String FNI-FE4BD156E939****

節點實例ID

示例

請求示例

http(s)://[Endpoint]/?Action=DescribeFlowNodeInstance
&ProjectId=FP-7A1018ADE917****
&Id=FNI-FE4BD156E939****
&RegionId=cn-hangzhou
&公共請求參數

正常返回示例

XML格式 

HTTP/1.1 200 OK
Content-Type:application/xml

<DescribeFlowNodeInstanceResponse>
    <Status>OK</Status>
    <Type>JOB</Type>
    <EnvConf>{"key":"value"}</EnvConf>
    <ProjectId>FP-7A1018ADE917****</ProjectId>
    <RetryInterval>15</RetryInterval>
    <JobType>HIVE_SQL</JobType>
    <Mode>YARN</Mode>
    <ExternalInfo>empty</ExternalInfo>
    <GmtModified>1540796247000</GmtModified>
    <ExternalChildIds>application_1541559535023_34028</ExternalChildIds>
    <MonitorConf>{"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]}</MonitorConf>
    <ExternalStatus>SUCCESS</ExternalStatus>
    <RequestId>1549175a-6d14-4c8a-89f9-5e28300f6d7e</RequestId>
    <JobName>myJob</JobName>
    <RetryPolicy>無</RetryPolicy>
    <Adhoc>true</Adhoc>
    <ExternalId>application_1541559535023_34027</ExternalId>
    <Pending>true</Pending>
    <ClusterId>C-F32FB31D8295****</ClusterId>
    <MaxRetry>0</MaxRetry>
    <FailAct>STOP</FailAct>
    <JobParams>ls -l</JobParams>
    <FlowInstanceId>FI-7CAF9709CD32****</FlowInstanceId>
    <ParamConf>{"date":"${yyyy-MM-dd}"}</ParamConf>
    <HostName>emr-header-1.cluster-12345</HostName>
    <FlowId>F-35683D0E4573****</FlowId>
    <Retries>0</Retries>
    <EndTime>1540796248000</EndTime>
    <StartTime>1540796237000</StartTime>
    <RunConf>{"priority":1,"userName":"hadoop","memory":2048,"cores":1}</RunConf>
    <ExternalSubId>container_1541559535023_34027_01_000001</ExternalSubId>
    <NodeName>812589f5</NodeName>
    <JobId>FJ-A23BD131A862****</JobId>
    <ClusterName>myCluster</ClusterName>
    <GmtCreate>1540796236000</GmtCreate>
    <Duration>600</Duration>
    <Id>FNI-FE4BD156E939****</Id>
</DescribeFlowNodeInstanceResponse>

JSON格式 

HTTP/1.1 200 OK
Content-Type:application/json

{
  "Status" : "OK",
  "Type" : "JOB",
  "EnvConf" : "{\"key\":\"value\"}",
  "ProjectId" : "FP-7A1018ADE917****",
  "RetryInterval" : "15",
  "JobType" : "HIVE_SQL",
  "Mode" : "YARN",
  "ExternalInfo" : "empty",
  "GmtModified" : 1540796247000,
  "ExternalChildIds" : "application_1541559535023_34028",
  "MonitorConf" : "{\"inputs\":[{\"type\":\"KAFKA\",\"clusterId\":\"C-1234567\",\"topics\":\"kafka_topic\",\"consumer.group\":\"kafka_consumer_group\"}],\"outputs\":[{\"type\":\"KAFKA\",\"clusterId\":\"C-1234567\",\"topics\":\"kafka_topic\"}]}",
  "ExternalStatus" : "SUCCESS",
  "RequestId" : "1549175a-6d14-4c8a-89f9-5e28300f6d7e",
  "JobName" : "myJob",
  "RetryPolicy" : "無",
  "Adhoc" : true,
  "ExternalId" : "application_1541559535023_34027",
  "Pending" : true,
  "ClusterId" : "C-F32FB31D8295****",
  "MaxRetry" : "0",
  "FailAct" : "STOP",
  "JobParams" : "ls -l",
  "FlowInstanceId" : "FI-7CAF9709CD32****",
  "ParamConf" : "{\"date\":\"${yyyy-MM-dd}\"}",
  "HostName" : "emr-header-1.cluster-12345",
  "FlowId" : "F-35683D0E4573****",
  "Retries" : 0,
  "EndTime" : 1540796248000,
  "StartTime" : 1540796237000,
  "RunConf" : "{\"priority\":1,\"userName\":\"hadoop\",\"memory\":2048,\"cores\":1}",
  "ExternalSubId" : "container_1541559535023_34027_01_000001",
  "NodeName" : "812589f5",
  "JobId" : "FJ-A23BD131A862****",
  "ClusterName" : "myCluster",
  "GmtCreate" : 1540796236000,
  "Duration" : 600,
  "Id" : "FNI-FE4BD156E939****"
}

錯誤碼

訪問錯誤中心查看更多錯誤碼。

訪問錯誤中心查看更多錯誤碼。