FlinkApplication

A Flink application.

Syntax

{
  "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"
  },
  "job": {
    "id": "string",
    "name": "string",
    "jarUri": "string",
    "entryClass": "string",
    "args": [
      "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 application ID.

    • Schema ResourceId

  • 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 deployed in the Flink application.

    • Type array
    • Items
      • Type string

  • plugins ^required

    A list of plugins deployed in 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 information of the Flink application.

    • Schema FlinkJob

  • 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