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!

FlinkSessionJobSpec

The specification to create a Flink session job.

Syntax

json
{
  "name": "string",
  "flinkConfiguration": {
    "string": "string"
  },
  "job": {
    "jarUri": "string",
    "entryClass": "string",
    "args": [
      "string"
    ]
  }
}

Type Definition

  • Type object
  • Properties
    • name required

      The Flink session job name.

    • flinkConfiguration required

      The Flink configuration specific to the Flink session job. This overrides the Flink configuration of the Flink session cluster when applicable. Some configuration options may not have an effect if they cannot be overridden by session jobs.

    • job required

      The job specification of the Flink session job.