Skip to content

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!

FlinkSession

A Flink session.

Syntax

json
{
  "id": "string",
  "name": "string",
  "runtime": "FLINK_1_17 | FLINK_1_18",
  "jars": [
    "string"
  ],
  "plugins": [
    {
      "name": "string",
      "jars": [
        "string"
      ]
    }
  ],
  "flinkConfiguration": {
    "string": "string"
  },
  "logConfiguration": {
    "string": "string"
  },
  "jobManagerResource": {
    "cpu": 0,
    "memory": "string",
    "ephemeralStorage": "string"
  },
  "taskManagerResource": {
    "cpu": 0,
    "memory": "string",
    "ephemeralStorage": "string"
  },
  "state": "PENDING | RUNNING | DELETING | FAILED",
  "createdAt": "YYYY-MM-DDTHH:mm:ss.sssZ",
  "updatedAt": "YYYY-MM-DDTHH:mm:ss.sssZ"
}

Type Definition

  • Type object
  • Properties
    • id required

      The Flink session ID.

    • name required

      The Flink session name.

    • runtime required

      The runtime of the Flink session.

    • jars required

      A list of JAR files deployed in the Flink session.

      • Type array
      • Items
        • Type string
    • plugins required

      A list of plugins deployed in the Flink session.

      • Type array
      • Items

        The configuration of a Flink plugin.

    • flinkConfiguration required

      The Flink configuration of the Flink session.

    • logConfiguration required

      The log configuration of the Flink session.

    • jobManagerResource required

      The resource configuration of the Flink JobManager containers.

    • taskManagerResource required

      The resource configuration of the Flink TaskManager containers.

    • state required

      The state of the Flink session.

    • createdAt required

      The time when the Flink session was created.

      • Type string
      • Format date-time
    • updatedAt required

      The time when the Flink session was last updated.

      • Type string
      • Format date-time