FlinkApplicationSpec

The specification to create a Flink application.

Syntax

{
  "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"
  },
  "job": {
    "jarUri": "string",
    "entryClass": "string",
    "args": [
      "string"
    ]
  }
}

Type Definition

• 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