この操作では、ジョブを変更します。

デバッグ

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

リクエストパラメーター

パラメーター データ型 必須 例 説明
Action String 必須 ModifyFlowJob

実行する操作です。 この値を ModifyFlowJob に設定します。
Id String 必須 FJ-BCCAE48B90CCB37B

ジョブの ID です。
ProjectId String 必須 FP-257A173659F59685

プロジェクトの ID です。
RegionId String 必須 cn-hangzhou

プロジェクトが配置されているリージョンの ID です。
ClusterId String 任意 C-A23BD131A862F184

クラスターの ID です。
Description String 任意 This is the description of a job

ジョブの説明です。
EnvConf String 任意 {"key":"value"}

ジョブのために設定された環境変数です。
FailAct String 任意 CONTINUE

ノードインスタンスの操作に失敗したときに実行する操作です。 有効値:

  • CONTINUE: ノードのインスタンスをスキップします。
  • STOP: ワークフローインスタンスを停止します。
MaxRetry Integer 任意 5

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

  • 有効値: 0～5 です。
Mode 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 ジョブのみに適用します。

Name String 任意 my_shell_job

ジョブの名前です。
ParamConf String 任意 {"date":"${yyyy-MM-dd}"}

ジョブの設定パラメーターです。
Params String 任意 ls -l

ジョブの内容です。
ResourceList.N.Alias String 任意 demo.jar

リソースのエイリアスです。
ResourceList.N.Path String 任意 oss://path/demo.jar

リソースのストレージパスです。 リソースは、OSS および HDFS に保存することができます。
RetryInterval Long 任意 200

ノードインスタンスを実行するための連続した再試行の間隔です。 有効な値: 0 ~ 300 です。 単位: 秒です。
RunConf String 任意 {"priority":1,"userName":"hadoop","memory":2048,"cores":1}

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

  • priority: ジョブの優先度です。
  • userName: ジョブをサミットする Linux ユーザーの名前です。
  • memory: ジョブに割り当てられたメモリです。 単位: MB です。
  • cores: ジョブに割り当てられた vCPU の数です。

レスポンスパラメーター

パラメーター データ型 例 説明
Data Boolean true

操作の結果です。
RequestId String 549175a-6d14-4c8a-89f9-5e28300f6d7e

リクエストの ID です。

コーディング例

リクエストの例


/？ Action = ModifyFlowJob
&Id=FJ-BBCAE48B90CCB37B
&ProjectId=FP-257A173659F59685
&RegionId=cn-hangzhou
&ClusterId=C-A23BD131A862F184
&Description=This is the description of a job
&EnvConf={"key":"value"}
&FailAct=CONTINUE
&MaxRetry=5
＆Mode=YARN
&MonitorConf={"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]}
&Name=my_shell_job
&ParamConf={"date":"${yyyy-MM-dd}"}＆ParamConf = {"date"： "$ {yyyy-MM-dd}"}
&Params=ls -l
&ResourceList.1.Alias=demo.jar
&ResourceList.1.Path=oss://path/demo.jar
&RetryInterval=200
&RunConf={"priority":1,"userName":"hadoop","memory":2048,"cores":1}
&<Common request parameters>

成功レスポンスの例

XML 形式 

<ModifyFlowJobResponse>
	  <RequestId> ECC2D0D1-B6D5-468D-B698-30E8805EB574 </ RequestId>
	  <Data>true</Data>
</ModifyFlowJobResponse>

JSON 形式 

{
	"Data":true,
	"RequestId":"ECC2D0D1-B6D5-468D-B698-30E8805EB574"
}

エラーコード

エラーコード一覧については、『API エラーセンター』 をご参照ください。