List Flink Jobs

List all Flink jobs for the current tenant/service.

GET/flink_jobs/

Authorization

AuthorizationBearer token · headerrequired

Responses

200

Successful Response

Array of app__models__api__flink_jobs_api_models__FlinkJobResponse

_idstringrequired

namestringrequired

job_typeapp__models__api__flink_jobs_api_models__FlinkJobTypeEnumrequired

Allowed:pyflinkjar

statusFlinkJobStatusEnumrequired

Allowed:CREATEDDEPLOYINGRUNNINGCANCELLINGCANCELLEDFAILEDFINISHED

flink_job_namestringrequired

flink_job_idstring | null

Show properties

Any of:

string

string

null

null

parallelisminteger

default: 1

created_bystring | null

Show properties

Any of:

string

string

null

null

created_timestampstring<date-time> | null

Show properties

Any of:

string<date-time>

string<date-time>

null

null

updated_timestampstring<date-time> | null

Show properties

Any of:

string<date-time>

string<date-time>

null

null

Request

curl -X GET 'https://api.streamkap.com/flink_jobs/' \
  -H 'Authorization: Bearer YOUR_TOKEN'

const response = await fetch("https://api.streamkap.com/flink_jobs/", {
  method: "GET",
  headers: {
    "Authorization": "Bearer YOUR_TOKEN"
  }
});

import requests

response = requests.get(
    "https://api.streamkap.com/flink_jobs/",
    headers={
        "Authorization": "Bearer YOUR_TOKEN"
    },
)

Response

[
  {
    "_id": "string",
    "name": "string",
    "job_type": "pyflink",
    "status": "CREATED",
    "flink_job_name": "string",
    "flink_job_id": "string",
    "parallelism": 1,
    "created_by": "string",
    "created_timestamp": "2019-08-24T14:15:22Z",
    "updated_timestamp": "2019-08-24T14:15:22Z"
  }
]