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	String	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.

Parent topic: Flink Job-related APIs

Previous topic: Querying Job Details

Next topic: Stopping Jobs in Batches