Flink Jobs

Deploy Pyflink Job

Changed on

Deploy a PyFlink job.

Either upload a Python file as multipart OR provide inline python_code as a form field. Form fields: name, parallelism (default 1), job_args (JSON string), python_code (alternative to file).

post/flink_jobs/pyflink

Request

Request body multipart/form-data

python_filestring binary nullable

Response

Successful Response

_idstring required
namestring required
job_type'pyflink' | 'jar' required
status'CREATED' | 'DEPLOYING' | 'RUNNING' | 'CANCELLING' | 'CANCELLED' | 'FAILED' | 'FINISHED' required
flink_job_namestring required
flink_job_idstring nullable
parallelisminteger
created_bystring nullable
created_timestampstring date-time nullable
updated_timestampstring date-time nullable

Changes

    • warning

      added the new CANCELLING enum value to the response property for the response status