この操作では、ジョブを変更します。
デバッグ
リクエストパラメーター
パラメーター | データ型 | 必須 | 例 | 説明 |
---|---|---|---|---|
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 |
ノードインスタンスの操作に失敗したときに実行する操作です。 有効値:
|
MaxRetry | Integer | 任意 | 5 |
障害が生じた場合にノードインスタンスを実行する最大再試行回数です。
|
Mode | String | 任意 | YARN |
ジョブの送信モードです。 有効な値: 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} |
ジョブに設定されたスケジュールパラメーターです。
|
レスポンスパラメーター
パラメーター | データ型 | 例 | 説明 |
---|---|---|---|
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 エラーセンター』 をご参照ください。