Querying the Job Execution Plan¶

Function¶

This API is used to query a job execution plan.

URI¶

URI format
GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph

Parameter description

**Table 1** URI parameters¶
Parameter	Mandatory	Type	Description
project_id	Yes	String	Project ID, which is used for resource isolation. For details about how to obtain its value, see Obtaining a Project ID.
job_id	Yes	Long	Job ID.

Request¶

None

Response¶

**Table 2** Response parameters¶
Parameter	Mandatory	Type	Description
is_success	No	Boolean	Whether the request is successful.
message	No	String	Message content.
execute_graph	No	Object	Response parameter for querying a job plan. For details, see Table 3.

**Table 3** **execute_graph** parameters¶
Parameter	Mandatory	Type	Description
jid	No	String	ID of a Flink job.
name	No	String	Name of a Flink job.
isStoppable	No	Boolean	Whether a job can be stopped.
state	No	String	Execution status of a job.
start-time	No	Long	Time when a job is started.
end-time	No	Long	Time when a job is stopped.
duration	No	Long	Running duration of a job.

Example Request¶

None

Example Response¶

{
    "is_success": "true",
  "message": "Querying the job execution graph succeeds.",
    "execute_graph": {
        "jid": "4e966f43f2c90b0e1bf3188ecf55504b",
        "name": "",
        "isStoppable": false,
        "state": "RUNNING",
        "start-time": 1578904488436,
        "end-time": -1,
        "duration": 516274
    }
}

Status Codes¶

**Table 4** Status codes¶
Status Code	Description
200	Querying the job execution plan succeeds.
400	The input parameter is invalid.

Error Codes¶

If an error occurs when this API is invoked, the system does not return the result similar to the preceding example, but returns the error code and error information. For details, see Error Codes.

last updated: 2024-11-20 15:34 UTC - commit: c856450509a511f9057fb9577287974ed6fce406