---
title: "Create a Flink Application"
method: POST
path: "/project/{project}/service/{service_name}/flink/application"
tags: ["Service:_Flink"]
---

# Create a Flink Application

`POST /project/{project}/service/{service_name}/flink/application`

## Path parameters

- `project` string, required
- `service_name` string, required

## Request body

- ServiceFlinkCreateApplicationRequestBody — ServiceFlinkCreateApplicationRequestBody
  - `application_version` object — Flink ApplicationVersion
    - `sinks` object[], required — Sinks
      - `create_table` string, required — The CREATE TABLE statement
      - `integration_id` string — Integration ID
    - `sources` object[], required — Sources
      - `create_table` string, required — The CREATE TABLE statement
      - `integration_id` string — Integration ID
    - `statement` string, required — The INSERT INTO SQL statement that will be performed as a job
  - `name` string, required — Application name

## Response `200`

Response

- ServiceFlinkCreateApplicationResponse — ServiceFlinkCreateApplicationResponse
  - `application_versions` object[], required — ApplicationVersions
    - `created_at` string, required — The creation timestamp of this entity in ISO 8601 format, always in UTC
    - `created_by` string, required — The creator of this entity
    - `id` string, required — ApplicationVersion ID
    - `sinks` object[], required — Sinks
      - `columns` object[], required — Columns
        - `data_type` string, required — The data type of the column
        - `extras` string — Column extra information
        - `key` string — The key info of the column
        - `name` string, required — The name of the column
        - `nullable` boolean, required — Whether the column is nullable, i.e. if true, the column is NOT NULL
        - `watermark` string — Information of the watermark if the column is used for watermark.
      - `create_table` string, required — The CREATE TABLE statement
      - `integration_id` string — Integration ID
      - `options` object, required — Option
      - `table_id` string, required — Sink ID
      - `table_name` string, required — Table name
    - `sources` object[], required — Sources
      - `columns` object[], required — Columns
        - `data_type` string, required — The data type of the column
        - `extras` string — Column extra information
        - `key` string — The key info of the column
        - `name` string, required — The name of the column
        - `nullable` boolean, required — Whether the column is nullable, i.e. if true, the column is NOT NULL
        - `watermark` string — Information of the watermark if the column is used for watermark.
      - `create_table` string, required — The CREATE TABLE statement
      - `integration_id` string — Integration ID
      - `options` object, required — Option
      - `table_id` string, required — Source ID
      - `table_name` string, required — Table name
    - `statement` string, required — The INSERT INTO SQL statement that will be performed as a job
    - `version` integer, required — Version number
  - `created_at` string, required — The creation timestamp of this entity in ISO 8601 format, always in UTC
  - `created_by` string, required — The creator of this entity
  - `current_deployment` object — Flink ApplicationDeployment
    - `created_at` string, required — The creation timestamp of this entity in ISO 8601 format, always in UTC
    - `created_by` string, required — The creator of this entity
    - `error_msg` string — Error message describing what caused deployment to fail
    - `id` string, required — Deployment ID
    - `job_id` string — Job ID
    - `last_savepoint` string — Job savepoint
    - `parallelism` integer, required — Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x number_of_task_slots), or every new job created will fail.
    - `restart_enabled` boolean, required — Specifies whether a Flink Job is restarted in case it fails
    - `starting_savepoint` string — Job savepoint
    - `status` 'INITIALIZING' | 'CREATED' | 'RUNNING' | 'FAILING' | 'FAILED' | 'SAVING' | 'CANCELLING_REQUESTED' | 'CANCELLING' | 'CANCELED' | 'SAVING_AND_STOP_REQUESTED' | 'SAVING_AND_STOP' | 'FINISHED' | 'RESTARTING' | 'SUSPENDED' | 'DELETE_REQUESTED' | 'DELETING' | 'RECONCILING', required — Deployment status
    - `version_id` string, required — ApplicationVersion ID
  - `errors` object[] — List of errors occurred during request processing
    - `message` string, required — Printable error message
    - `more_info` string — URL to the documentation of the error
    - `status` integer, required — HTTP error status code
  - `id` string, required — Application ID
  - `message` string — Printable result of the request
  - `name` string, required — Application name
  - `updated_at` string, required — The update timestamp of this entity in ISO 8601 format, always in UTC
  - `updated_by` string, required — The latest updater of this entity

---

[API](https://skmtc.net/aiven/apis/aiven-api-documentation.md) · [All operations](https://skmtc.net/aiven/apis/aiven-api-documentation/llms.txt) · [OpenAPI document](https://skmtc-service-staging.skmtc.workers.dev/v1/apis/aiven/aiven-api-documentation/revisions/cbfbf0f96a48/schema)