Job Information

Job Client

JobClient.get_job_id()	Returns the JobID that uniquely identifies the job this client is scoped to.
JobClient.get_job_status()	Requests the JobStatus of the associated job.
JobClient.cancel()	Cancels the associated job.
JobClient.stop_with_savepoint(...[, ...])	Stops the associated job on Flink cluster.
JobClient.trigger_savepoint([...])	Triggers a savepoint for the associated job.
JobClient.get_accumulators()	Requests the accumulators of the associated job.
JobClient.get_job_execution_result()	Returns the JobExecutionResult result of the job execution of the submitted job.

JobExecution Result

JobExecutionResult.get_job_id()	Returns the JobID assigned to the job by the Flink runtime.
JobExecutionResult.get_net_runtime()	Gets the net execution time of the job, i.e., the execution time in the parallel system, without the pre-flight steps like the optimizer.
JobExecutionResult.get_accumulator_result(...)	Gets the accumulator with the given name.
JobExecutionResult.get_all_accumulator_results()	Gets all accumulators produced by the job.

Job Status

JobStatus(value)

Possible states of a job once it has been accepted by the job manager.