The managed Apache Flink service on the LakeSail platform is deprecated.

LakeSail is building Sail, an open-source computation framework in Rust to seamlessly integrate stream-processing, batch-processing, and compute-intensive (AI) workloads. The LakeSail platform will offer the managed solution for Sail. Existing PySpark and Flink SQL workloads can be migrated with ease. Please stay tuned and contact us if you are interested!

CreateFlinkApplication

Creates a Flink application.

post/api/flink/v1/workspaces/{ws}/applications

Path Parameters

ws ^required
A workspace ID.
- Schema ResourceId
- Type string
- Minimum Length 1
- Maximum Length 20
- Pattern ^[A-Z0-9]+$

Query Parameters

This operation does not have query parameters.

Request Body

Schema FlinkApplicationSpec
Type object
Properties
- name ^required
  The Flink application name.
  - Schema ResourceName
- runtime ^required
  The runtime of the Flink application.
  - Schema FlinkRuntime
- jars ^required
  A list of JAR files to be used for the Flink application.
  - Type array
  - Items
    Type string
- plugins ^required
  A list of plugins to be used for the Flink application.
  - Type array
  - Items
    The configuration of a Flink plugin.
    
    Schema FlinkPlugin
- flinkConfiguration ^required
  The Flink configuration of the Flink application.
  - Schema FlinkConfiguration
- logConfiguration ^required
  The log configuration of the Flink application.
  - Schema FlinkLogConfiguration
- jobManagerResource ^required
  The resource configuration of the Flink JobManager containers.
  - Schema ContainerResource
- taskManagerResource ^required
  The resource configuration of the Flink TaskManager containers.
  - Schema ContainerResource
- job ^required
  The job specification of the Flink application.
  - Schema FlinkJobSpec

Responses

201 Response

The Flink application was created successfully.

Schema FlinkApplicationSummary
Type object
Properties
- id ^required
  The Flink application ID.
  - Schema ResourceId
- name ^required
  The Flink application name.
  - Schema ResourceName
- state ^required
  The state of the Flink application.
  - Schema FlinkApplicationState
- createdAt ^required
  The time when the Flink application was created.
  - Type string
  - Format date-time
- updatedAt ^required
  The time when the Flink application was last updated.
  - Type string
  - Format date-time

400 Response

The requested operation cannot be performed because the request is malformed.

Schema Error
Type object
Properties
- message ^required
  An error message.
  - Type string

401 Response

The requested operation cannot be performed because the request lacks valid authentication credentials.

Schema Error
Type object
Properties
- message ^required
  An error message.
  - Type string

403 Response

The identity is not allowed to perform the requested operation for the resource involved.

Schema Error
Type object
Properties
- message ^required
  An error message.
  - Type string

404 Response

The resource or dependent resources involved in the requested operation do not exist.

Schema Error
Type object
Properties
- message ^required
  An error message.
  - Type string

Default Response

The requested operation failed with an error.

Schema Error
Type object
Properties
- message ^required
  An error message.
  - Type string