pyflink.common.job_status.JobStatus#

class JobStatus(value)[source]#

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

CREATED:

Job is newly created, no task has started to run.

RUNNING:

Some tasks are scheduled or running, some may be pending, some may be finished.

FAILING:

The job has failed and is currently waiting for the cleanup to complete.

FAILED:

The job has failed with a non-recoverable task failure.

CANCELLING:

Job is being cancelled.

CANCELED:

Job has been cancelled.

FINISHED:

All of the job’s tasks have successfully finished.

RESTARTING:

The job is currently undergoing a reset and total restart.

SUSPENDED:

The job has been suspended which means that it has been stopped but not been removed from a potential HA job store.

RECONCILING:

The job is currently reconciling and waits for task execution report to recover state.

New in version 1.11.0.

Methods

`is_globally_terminal_state`()	Checks whether this state is <i>globally terminal</i>.
`is_terminal_state`()	Checks whether this state is locally terminal.

Attributes