Deploy Pyflink Job

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

Deploy Pyflink Job

cURL

curl --request POST \
  --url https://api.streamkap.com/flink_jobs/pyflink \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: multipart/form-data' \
  --form 'python_file=<string>'

200

{
  "_id": "<string>",
  "name": "<string>",
  "flink_job_name": "<string>",
  "flink_job_id": "<string>",
  "parallelism": 1,
  "created_by": "<string>",
  "created_timestamp": "2023-11-07T05:31:56Z",
  "updated_timestamp": "2023-11-07T05:31:56Z"
}

Authorizations

Authorization · string · header · required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Body

multipart/form-data

python_file · string | null

Response

200

application/json

Successful Response

_id · string · required

name · string · required

job_type · enum<string> · required

Available options: pyflink, jar

status · enum<string> · required

Available options: CREATED, DEPLOYING, RUNNING, FAILED, CANCELLED, FINISHED

flink_job_name · string · required

flink_job_id · string | null

parallelism · integer · default: 1

created_by · string | null

created_timestamp · string<date-time> | null

updated_timestamp · string<date-time> | null