この操作では、ノードインスタンスを照会します。

デバッグ

OpenAPI Explorer は署名値を自動的に計算します。 OpenAPI Explorer を使用すると、API を簡単に設定できます。 OpenAPI Explorer は、各種 SDK に用意されている API のサンプルコードを動的に生成します。

リクエストパラメーター

パラメーター データ型 必須/任意 説明
Action String 必須 DescribeFlowNodeInstance

実行する操作。 値を DescribeFlowNodeInstance に設定します。

Id String 必須 FNI-FE4BD156E939 ****

ノードインスタンスの ID。

ProjectId String 必須 FP-7A1018ADE917****

プロジェクトの ID。

RegionId String 必須 cn-hangzhou

プロジェクトが属するリージョンの ID。

レスポンスパラメーター

パラメーター データ型 説明
Adhoc Boolean true

ジョブが一時的なクエリジョブであるか。

ClusterId String C-F32FB31D8295 ****

クラスターの ID。

ClusterName String myCluster

クラスターの名前。

Duration Long 200

ノードインスタンスの実行期間。

EndTime Long 1540796248000

ノードインスタンスの停止時刻。

EnvConf String {"key":"value"}

ジョブ用に設定された環境変数。

ExternalChildIds String application_1541559535023_34028

アプリケーションの ID。

ExternalId String application_1541559535023_34027

ランチャーアプリケーションの ID。

ExternalInfo String empty

エラー診断情報など、ノードインスタンスの外部情報。

ExternalStatus String SUCCESS

ノードインスタンスの外部ステータス。 有効値:

  • SUBMITTED: ノードインスタンスが送信されました。
  • RUNNING: ノードインスタンスは実行中です。
  • SUCCESS: ノードインスタンスの実行に成功しました。
  • FAIL: ノードインスタンスの実行に失敗しました。
  • KILL_FAIL: ノードインスタンスの停止に失敗しました。
  • KILL_SUCCESS: ノードインスタンスの停止に成功しました。
ExternalSubId String container_1541559535023_34027_01_000001

ランチャーコンテナの ID。

FailAct String STOP

ノードインスタンスで障害が発生した場合に実行する操作。 有効値:

  • STOP:ワークフローインスタンスを停止します。
  • CONTINUE:ノードインスタンスをスキップします。
FlowId String F-35683D0E4573 ****

ワークフローの ID。

FlowInstanceId String FI-7CAF9709CD32 ****

ワークフローインスタンスの ID。

GmtCreate Long 1540796236000

ワークフローの作成時刻。

GmtModified Long 1540796247000

ワークフローの変更時刻。

HostName String emr-header-1.cluster-12345

ノードインスタンスが実行されているホストの名前。 ホストはマスターホストまたはゲートウェイホストになります。 ホスト名の形式は、emr-header-1.cluster-12345 です。 hostname コマンドを実行すると、このパラメーターの値を確認できます。

Id String FNI-9D14A7CCF268 ****

ノードインスタンスの ID。

JobId String FJ-A23BD131A862****

ジョブの ID。

JobName String myJob

ジョブの名前。

JobParams String ls -l

ジョブコンテンツ。

JobType String HIVE_SQL

ジョブの種類。

MaxRetry String 0

障害が発生した場合に、ノードインスタンスの実行を再試行する最大回数。

モード String YARN

ジョブの送信モード。 有効な値 : YARN 、 LOCAL。 YARN: ワーカーノードからジョブを送信します。 LOCAL: ヘッダーまたはゲートウェイノードからジョブを送信します。

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 ジョブのみに適用します。

NodeName String Node Name

ノード名。

ParamConf String {"date":"${yyyy-MM-dd}"}

ジョブの設定パラメーター。

Pending Boolean true

ノードインスタンスの実行が停止済みであるか。

ProjectId String FP-7A1018ADE917****

プロジェクトの ID。

RequestId String 1549175a-6d14-4c8a-89f9-5e28300f6d7e

リクエストの ID。

Retries Integer 0

ノードインスタンス実行の再試行回数。

RetryInterval String 15

ノードインスタンスの実行を連続して再試行する間隔。 単位:

RunConf String {"priority":1,"userName":"hadoop","memory":2048,"cores":1}

ジョブに設定されたスケジュールパラメーター。

  • priority: ジョブの優先度。
  • userName: ジョブを送信した Linux ユーザーの名前。
  • memory: ジョブに割り当てられたメモリ。 単位:MB。
  • cores: ジョブに割り当てられた vCPU の数。
StartTime Long 1540796237000

ノードインスタンスの実行開始時刻。

Status String OK

ノードインスタンスのステータス。 有効値:

  • PREP: ノードインスタンスを準備しています。
  • SUBMITTING: ノードインスタンスを送信中です。
  • RUNNING: ノードインスタンスを実行中です。
  • DONE: ノードインスタンスの実行が完了しました。
  • OK: ノードインスタンスの実行に成功しました。
  • FAILED: ノードインスタンスの実行に失敗しました。
  • KILLED: ノードインスタンスが停止しています。
  • KILL_FAILED: ノードインスタンスの終了に失敗しました。
  • START_RETRY: ノードインスタンスの再起動中です。
Type String JOB

ノードの種類。 有効値:

  • JOB:ジョブノード
  • CLUSTER:クラスターノード
  • START:開始ノード
  • END:終了ノード

リクエストの例


http(s)://[Endpoint]/? Action=DescribeFlowNodeInstance
&Id=FNI-FE4BD156E939****
&ProjectId=FP-7A1018ADE917****
&RegionId=cn-hangzhou
&<共通リクエストパラメーター>

通常のレスポンス例

XML 形式

<DescribeFlowNodeInstanceResponse>
	  <Data>
		    <FailAct>STOP</FailAct>
		    <EndTime>1542884476000</EndTime>
		    <NodeName>812589f5</NodeName>
		    <GmtModified>1542884475000</GmtModified>
		    <JobName>success</JobName>
		    <ExternalStatus>SUCCESS</ExternalStatus>
		    <FlowId>F-60C9B1257A80****</FlowId>
		    <ParamConf>
			      <cyctime>2018-11-22 19:00:00</cyctime>
		    </ParamConf>
		    <ExternalInfo></ExternalInfo>
		    <Retries>0</Retries>
		    <ClusterName>mingbo-v199v1</ClusterName>
		    <JobId>FJ-EE3AF471B2E6****</JobId>
		    <HostName>emr-header-1.cluster-500159692</HostName>
		    <JobParams>
			sleep 10;
		exit 0;</JobParams>
		    <Status>OK</Status>
		    <RequestId>F5540D8F-06E8-4E3C-B47A-D75CED72A795</RequestId>
		    <ClusterId>C-F32FB31D8295****</ClusterId>
		    <ExternalId>application_1541559535023_34027</ExternalId>
		    <StartTime>1542884402000</StartTime>
		    <ProjectId>FP-3535FE0BE5224A47</ProjectId>
		    <FlowInstanceId>FI-C112BB938D2C****</FlowInstanceId>
		    <Duration>74000</Duration>
		    <ExternalSubId>container_1541559535023_34027_01_000001</ExternalSubId>
		    <MaxRetry>0</MaxRetry>
		    <Type>JOB</Type>
		    <GmtCreate>1542884401000</GmtCreate>
		    <JobType>SHELL</JobType>
		    <RetryInterval>15</RetryInterval>
		    <Id>FNI-E548777B9DCD****</Id>
		    <Pending>false</Pending>
	  </data>
	  <requestId>F5540D8F-06E8-4E3C-B47A-D75CED72A795</requestId>
</DescribeFlowNodeInstanceResponse>

JSON format

{
	"requestId":"F5540D8F-06E8-4E3C-B47A-D75CED72A795",
	"data":{
		"FailAct":"STOP",
		"Type":"JOB",
		"GmtModified":1542884475000,
		"FlowInstanceId":"FI-C112BB938D2C****",
		"RetryInterval":"15",
		"ClusterName":"mingbo-v199v1",
		"ExternalSubId":"container_1541559535023_34027_01_000001",
		"JobId":"FJ-EE3AF471B2E6****",
		"Duration":74000,
		"ExternalInfo":"",
		"StartTime":1542884402000,
		"ExternalStatus":"SUCCESS",
		"NodeName":"812589f5",
		"Retries":0,
		"ExternalId":"application_1541559535023_34027",
		"FlowId":"F-60C9B1257A80****",
		"JobName":"success",
		"GmtCreate":1542884401000,
		"HostName":"emr-header-1.cluster-500159692",
		"JobParams":"sleep 10;\nexit 0;",
		"JobType":"SHELL",
		"Status":"OK",
		"MaxRetry":"0",
		"ClusterId":"C-F32FB31D8295****",
		"RequestId":"F5540D8F-06E8-4E3C-B47A-D75CED72A795",
		"ParamConf":{
			"cyctime":"2018-11-22 19:00:00"
		},
		"Id":"FNI-E548777B9DCD****",
		"EndTime":1542884476000,
		"Pending":false,
		"ProjectId":"FP-3535FE0BE5224A47"
	}
}

エラーコード

エラーコードについては、「API エラーセンター」をご参照ください。