naftiko: 1.0.0-alpha2
info:
  label: Flink JobManager REST API
  description: 'Flink JobManager REST API. 69 operations. Lead operation: Apache Flink Delete Cluster. Self-contained Naftiko
    capability covering one Apache Flink business surface.'
  tags:
  - Apache Flink
  - Flink JobManager REST API
  created: '2026-05-19'
  modified: '2026-05-19'
binds:
- namespace: env
  keys:
    APACHE_FLINK_API_KEY: APACHE_FLINK_API_KEY
capability:
  consumes:
  - type: http
    namespace: rest
    baseUri: ''
    description: Flink JobManager REST API business capability. Self-contained, no shared references.
    resources:
    - name: cluster
      path: /cluster
      operations:
      - name: shutdowncluster
        method: DELETE
        description: Apache Flink Delete Cluster
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: config
      path: /config
      operations:
      - name: getdashboardconfiguration
        method: GET
        description: Apache Flink List Config
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: datasets
      path: /datasets
      operations:
      - name: getclusterdatasetlist
        method: GET
        description: Apache Flink List Datasets
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: datasets-delete-triggerid
      path: /datasets/delete/{triggerid}
      operations:
      - name: getclusterdatasetdeletestatus
        method: GET
        description: Apache Flink Get Datasets Delete
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: triggerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies an asynchronous operation trigger ID. The ID was returned
            then the operation was triggered.
          required: true
    - name: datasets-datasetid
      path: /datasets/{datasetid}
      operations:
      - name: deleteclusterdataset
        method: DELETE
        description: Apache Flink Delete Datasets
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: datasetid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a cluster data set.
          required: true
    - name: jars
      path: /jars
      operations:
      - name: getjarlist
        method: GET
        description: Apache Flink List Jars
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jars-upload
      path: /jars/upload
      operations:
      - name: uploadjar
        method: POST
        description: Apache Flink Create Jars Upload
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: true
    - name: jars-jarid
      path: /jars/{jarid}
      operations:
      - name: deletejar
        method: DELETE
        description: Apache Flink Delete Jars
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jarid
          in: path
          type: string
          description: String value that identifies a jar. When uploading the jar a path is returned, where the filename is
            the ID. This value is equivalent to the `id` field in the l
          required: true
    - name: jars-jarid-plan
      path: /jars/{jarid}/plan
      operations:
      - name: generateplanfromjar
        method: POST
        description: Apache Flink Create Jars Plan
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jarid
          in: path
          type: string
          description: String value that identifies a jar. When uploading the jar a path is returned, where the filename is
            the ID. This value is equivalent to the `id` field in the l
          required: true
        - name: programArg
          in: query
          type: string
          description: Comma-separated list of program arguments.
        - name: entry-class
          in: query
          type: string
          description: String value that specifies the fully qualified name of the entry point class. Overrides the class
            defined in the jar file manifest.
        - name: parallelism
          in: query
          type: integer
          description: Positive integer value that specifies the desired parallelism for the job.
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jars-jarid-run
      path: /jars/{jarid}/run
      operations:
      - name: submitjobfromjar
        method: POST
        description: Apache Flink Create Jars Run
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jarid
          in: path
          type: string
          description: String value that identifies a jar. When uploading the jar a path is returned, where the filename is
            the ID. This value is equivalent to the `id` field in the l
          required: true
        - name: allowNonRestoredState
          in: query
          type: boolean
          description: Boolean value that specifies whether the job submission should be rejected if the savepoint contains
            state that cannot be mapped back to the job.
        - name: savepointPath
          in: query
          type: string
          description: String value that specifies the path of the savepoint to restore the job from.
        - name: programArg
          in: query
          type: string
          description: Comma-separated list of program arguments.
        - name: entry-class
          in: query
          type: string
          description: String value that specifies the fully qualified name of the entry point class. Overrides the class
            defined in the jar file manifest.
        - name: parallelism
          in: query
          type: integer
          description: Positive integer value that specifies the desired parallelism for the job.
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobmanager-config
      path: /jobmanager/config
      operations:
      - name: getclusterconfigurationinfo
        method: GET
        description: Apache Flink List Jobmanager Config
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobmanager-environment
      path: /jobmanager/environment
      operations:
      - name: getjobmanagerenvironment
        method: GET
        description: Apache Flink List Jobmanager Environment
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobmanager-logs
      path: /jobmanager/logs
      operations:
      - name: getjobmanagerloglist
        method: GET
        description: Apache Flink List Jobmanager Logs
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobmanager-metrics
      path: /jobmanager/metrics
      operations:
      - name: getjobmanagermetrics
        method: GET
        description: Apache Flink List Jobmanager Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: jobmanager-thread-dump
      path: /jobmanager/thread-dump
      operations:
      - name: getjobmanagerthreaddump
        method: GET
        description: Apache Flink List Jobmanager Thread-Dump
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobs
      path: /jobs
      operations:
      - name: getjobidswithstatusesoverview
        method: GET
        description: Apache Flink List Jobs
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobs-metrics
      path: /jobs/metrics
      operations:
      - name: getaggregatedjobmetrics
        method: GET
        description: Apache Flink List Jobs Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
        - name: agg
          in: query
          type: string
          description: 'Comma-separated list of aggregation modes which should be calculated. Available aggregations are:
            "min, max, sum, avg, skew".'
        - name: jobs
          in: query
          type: string
          description: Comma-separated list of 32-character hexadecimal strings to select specific jobs.
    - name: jobs-overview
      path: /jobs/overview
      operations:
      - name: getjobsoverview
        method: GET
        description: Apache Flink List Jobs Overview
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: jobs-jobid
      path: /jobs/{jobid}
      operations:
      - name: getjobdetails
        method: GET
        description: Apache Flink Get Jobs
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
      - name: canceljob
        method: PATCH
        description: Apache Flink Update Jobs
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: mode
          in: query
          type: string
          description: 'String value that specifies the termination mode. The only supported value is: "cancel".'
    - name: jobs-jobid-accumulators
      path: /jobs/{jobid}/accumulators
      operations:
      - name: getjobaccumulators
        method: GET
        description: Apache Flink List Jobs Accumulators
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: includeSerializedValue
          in: query
          type: boolean
          description: Boolean value that specifies whether serialized user task accumulators should be included in the response.
    - name: jobs-jobid-checkpoints
      path: /jobs/{jobid}/checkpoints
      operations:
      - name: getcheckpointingstatistics
        method: GET
        description: Apache Flink List Jobs Checkpoints
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
      - name: triggercheckpoint
        method: POST
        description: Apache Flink Create Jobs Checkpoints
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobs-jobid-checkpoints-config
      path: /jobs/{jobid}/checkpoints/config
      operations:
      - name: getcheckpointconfig
        method: GET
        description: Apache Flink List Checkpoints Config
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-checkpoints-details-checkpointid
      path: /jobs/{jobid}/checkpoints/details/{checkpointid}
      operations:
      - name: getcheckpointstatisticdetails
        method: GET
        description: Apache Flink Get Checkpoints Details
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: checkpointid
          in: path
          type: integer
          description: Long value that identifies a checkpoint.
          required: true
    - name: jobs-jobid-checkpoints-details-checkpointid-subtasks-vertexid
      path: /jobs/{jobid}/checkpoints/details/{checkpointid}/subtasks/{vertexid}
      operations:
      - name: gettaskcheckpointstatistics
        method: GET
        description: Apache Flink Get Details Subtasks
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: checkpointid
          in: path
          type: integer
          description: Long value that identifies a checkpoint.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-checkpoints-triggerid
      path: /jobs/{jobid}/checkpoints/{triggerid}
      operations:
      - name: getcheckpointstatus
        method: GET
        description: Apache Flink Get Jobs Checkpoints
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: triggerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies an asynchronous operation trigger ID. The ID was returned
            then the operation was triggered.
          required: true
    - name: jobs-jobid-clientHeartbeat
      path: /jobs/{jobid}/clientHeartbeat
      operations:
      - name: triggerheartbeat
        method: PATCH
        description: Apache Flink Update Jobs Clientheartbeat
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobs-jobid-config
      path: /jobs/{jobid}/config
      operations:
      - name: getjobconfig
        method: GET
        description: Apache Flink List Jobs Config
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-exceptions
      path: /jobs/{jobid}/exceptions
      operations:
      - name: getjobexceptions
        method: GET
        description: Apache Flink List Jobs Exceptions
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: maxExceptions
          in: query
          type: integer
          description: Comma-separated list of integer values that specifies the upper limit of exceptions to return.
        - name: failureLabelFilter
          in: query
          type: string
          description: Collection of string values working as a filter in the form of `key:value` pairs allowing only exceptions
            with ALL of the specified failure labels to be returne
    - name: jobs-jobid-execution-result
      path: /jobs/{jobid}/execution-result
      operations:
      - name: getjobexecutionresult
        method: GET
        description: Apache Flink List Jobs Execution-Result
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-jobmanager-config
      path: /jobs/{jobid}/jobmanager/config
      operations:
      - name: getjobmanagerjobconfiguration
        method: GET
        description: Apache Flink List Jobmanager Config
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-jobmanager-environment
      path: /jobs/{jobid}/jobmanager/environment
      operations:
      - name: getjobmanagerjobenvironment
        method: GET
        description: Apache Flink List Jobmanager Environment
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-jobmanager-log-url
      path: /jobs/{jobid}/jobmanager/log-url
      operations:
      - name: getjobmanagerlogurl
        method: GET
        description: Apache Flink List Jobmanager Log-Url
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-metrics
      path: /jobs/{jobid}/metrics
      operations:
      - name: getjobmetrics
        method: GET
        description: Apache Flink List Jobs Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: jobs-jobid-plan
      path: /jobs/{jobid}/plan
      operations:
      - name: getjobplan
        method: GET
        description: Apache Flink List Jobs Plan
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-rescaling
      path: /jobs/{jobid}/rescaling
      operations:
      - name: rescalejob
        method: PATCH
        description: Apache Flink Update Jobs Rescaling
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: parallelism
          in: query
          type: integer
          description: Positive integer value that specifies the desired parallelism.
          required: true
    - name: jobs-jobid-rescaling-triggerid
      path: /jobs/{jobid}/rescaling/{triggerid}
      operations:
      - name: getrescalingstatus
        method: GET
        description: Apache Flink Get Jobs Rescaling
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: triggerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies an asynchronous operation trigger ID. The ID was returned
            then the operation was triggered.
          required: true
    - name: jobs-jobid-resource-requirements
      path: /jobs/{jobid}/resource-requirements
      operations:
      - name: getjobresourcerequirements
        method: GET
        description: Apache Flink List Jobs Resource-Requirements
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
      - name: updatejobresourcerequirements
        method: PUT
        description: Apache Flink Update Jobs Resource-Requirements
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobs-jobid-savepoints
      path: /jobs/{jobid}/savepoints
      operations:
      - name: triggersavepoint
        method: POST
        description: Apache Flink Create Jobs Savepoints
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobs-jobid-savepoints-triggerid
      path: /jobs/{jobid}/savepoints/{triggerid}
      operations:
      - name: getsavepointstatus
        method: GET
        description: Apache Flink Get Jobs Savepoints
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: triggerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies an asynchronous operation trigger ID. The ID was returned
            then the operation was triggered.
          required: true
    - name: jobs-jobid-status
      path: /jobs/{jobid}/status
      operations:
      - name: getjobstatusinfo
        method: GET
        description: Apache Flink List Jobs Status
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
    - name: jobs-jobid-stop
      path: /jobs/{jobid}/stop
      operations:
      - name: triggerstopwithsavepoint
        method: POST
        description: Apache Flink Create Jobs Stop
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: jobs-jobid-taskmanagers-taskmanagerid-log-url
      path: /jobs/{jobid}/taskmanagers/{taskmanagerid}/log-url
      operations:
      - name: gettaskmanagerlogurl
        method: GET
        description: Apache Flink List Taskmanagers Log-Url
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: taskmanagerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies a task manager.
          required: true
    - name: jobs-jobid-vertices-vertexid
      path: /jobs/{jobid}/vertices/{vertexid}
      operations:
      - name: getjobvertexdetails
        method: GET
        description: Apache Flink Get Jobs Vertices
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-accumulators
      path: /jobs/{jobid}/vertices/{vertexid}/accumulators
      operations:
      - name: getjobvertexaccumulators
        method: GET
        description: Apache Flink List Vertices Accumulators
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-backpressure
      path: /jobs/{jobid}/vertices/{vertexid}/backpressure
      operations:
      - name: getjobvertexbackpressure
        method: GET
        description: Apache Flink List Vertices Backpressure
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-flamegraph
      path: /jobs/{jobid}/vertices/{vertexid}/flamegraph
      operations:
      - name: getjobvertexflamegraph
        method: GET
        description: Apache Flink List Vertices Flamegraph
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: type
          in: query
          type: string
          description: 'String value that specifies the Flame Graph type. Supported options are: "[FULL, ON_CPU, OFF_CPU]".'
        - name: subtaskindex
          in: query
          type: integer
          description: Positive integer value that identifies a subtask.
    - name: jobs-jobid-vertices-vertexid-jm-operator-metrics
      path: /jobs/{jobid}/vertices/{vertexid}/jm-operator-metrics
      operations:
      - name: getjobmanageroperatormetrics
        method: GET
        description: Apache Flink List Vertices Jm-Operator-Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: jobs-jobid-vertices-vertexid-metrics
      path: /jobs/{jobid}/vertices/{vertexid}/metrics
      operations:
      - name: getjobvertexmetrics
        method: GET
        description: Apache Flink List Vertices Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: jobs-jobid-vertices-vertexid-subtasks-accumulators
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/accumulators
      operations:
      - name: getsubtasksallaccumulators
        method: GET
        description: Apache Flink List Subtasks Accumulators
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-subtasks-metrics
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/metrics
      operations:
      - name: getaggregatedsubtaskmetrics
        method: GET
        description: Apache Flink List Subtasks Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
        - name: agg
          in: query
          type: string
          description: 'Comma-separated list of aggregation modes which should be calculated. Available aggregations are:
            "min, max, sum, avg, skew".'
        - name: subtasks
          in: query
          type: string
          description: Comma-separated list of integer ranges (e.g. "1,3,5-9") to select specific subtasks.
    - name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}
      operations:
      - name: getsubtaskcurrentattemptdetails
        method: GET
        description: Apache Flink Get Vertices Subtasks
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: subtaskindex
          in: path
          type: integer
          description: Positive integer value that identifies a subtask.
          required: true
    - name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}
      operations:
      - name: getsubtaskexecutionattemptdetails
        method: GET
        description: Apache Flink Get Subtasks Attempts
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: subtaskindex
          in: path
          type: integer
          description: Positive integer value that identifies a subtask.
          required: true
        - name: attempt
          in: path
          type: integer
          description: Positive integer value that identifies an execution attempt.
          required: true
    - name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt-accumulators
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}/accumulators
      operations:
      - name: getsubtaskexecutionattemptaccumulators
        method: GET
        description: Apache Flink List Attempts Accumulators
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: subtaskindex
          in: path
          type: integer
          description: Positive integer value that identifies a subtask.
          required: true
        - name: attempt
          in: path
          type: integer
          description: Positive integer value that identifies an execution attempt.
          required: true
    - name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-metrics
      path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/metrics
      operations:
      - name: getsubtaskmetrics
        method: GET
        description: Apache Flink List Subtasks Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
        - name: subtaskindex
          in: path
          type: integer
          description: Positive integer value that identifies a subtask.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: jobs-jobid-vertices-vertexid-subtasktimes
      path: /jobs/{jobid}/vertices/{vertexid}/subtasktimes
      operations:
      - name: getsubtaskstimes
        method: GET
        description: Apache Flink List Vertices Subtasktimes
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-taskmanagers
      path: /jobs/{jobid}/vertices/{vertexid}/taskmanagers
      operations:
      - name: getjobvertextaskmanagers
        method: GET
        description: Apache Flink List Vertices Taskmanagers
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: jobs-jobid-vertices-vertexid-watermarks
      path: /jobs/{jobid}/vertices/{vertexid}/watermarks
      operations:
      - name: getjobvertexwatermarks
        method: GET
        description: Apache Flink List Vertices Watermarks
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: jobid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job.
          required: true
        - name: vertexid
          in: path
          type: string
          description: 32-character hexadecimal string value that identifies a job vertex.
          required: true
    - name: overview
      path: /overview
      operations:
      - name: getclusteroverview
        method: GET
        description: Apache Flink List Overview
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: savepoint-disposal
      path: /savepoint-disposal
      operations:
      - name: triggersavepointdisposal
        method: POST
        description: Apache Flink Create Savepoint-Disposal
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: savepoint-disposal-triggerid
      path: /savepoint-disposal/{triggerid}
      operations:
      - name: getsavepointdisposalstatus
        method: GET
        description: Apache Flink Get Savepoint-Disposal
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: triggerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies an asynchronous operation trigger ID. The ID was returned
            then the operation was triggered.
          required: true
    - name: taskmanagers
      path: /taskmanagers
      operations:
      - name: gettaskmanagers
        method: GET
        description: Apache Flink List Taskmanagers
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: taskmanagers-metrics
      path: /taskmanagers/metrics
      operations:
      - name: getaggregatedtaskmanagermetrics
        method: GET
        description: Apache Flink List Taskmanagers Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
        - name: agg
          in: query
          type: string
          description: 'Comma-separated list of aggregation modes which should be calculated. Available aggregations are:
            "min, max, sum, avg, skew".'
        - name: taskmanagers
          in: query
          type: string
          description: Comma-separated list of 32-character hexadecimal strings to select specific task managers.
    - name: taskmanagers-taskmanagerid
      path: /taskmanagers/{taskmanagerid}
      operations:
      - name: gettaskmanagerdetails
        method: GET
        description: Apache Flink Get Taskmanagers
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: taskmanagerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies a task manager.
          required: true
    - name: taskmanagers-taskmanagerid-logs
      path: /taskmanagers/{taskmanagerid}/logs
      operations:
      - name: gettaskmanagerlogs
        method: GET
        description: Apache Flink List Taskmanagers Logs
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: taskmanagerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies a task manager.
          required: true
    - name: taskmanagers-taskmanagerid-metrics
      path: /taskmanagers/{taskmanagerid}/metrics
      operations:
      - name: gettaskmanagermetrics
        method: GET
        description: Apache Flink List Taskmanagers Metrics
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: taskmanagerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies a task manager.
          required: true
        - name: get
          in: query
          type: string
          description: Comma-separated list of string values to select specific metrics.
    - name: taskmanagers-taskmanagerid-thread-dump
      path: /taskmanagers/{taskmanagerid}/thread-dump
      operations:
      - name: gettaskmanagerthreaddump
        method: GET
        description: Apache Flink List Taskmanagers Thread-Dump
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: taskmanagerid
          in: path
          type: string
          description: 32-character hexadecimal string that identifies a task manager.
          required: true
  exposes:
  - type: rest
    namespace: rest-rest
    port: 8080
    description: REST adapter for Flink JobManager REST API. One Spectral-compliant resource per consumed operation, prefixed
      with /v1.
    resources:
    - path: /v1/cluster
      name: cluster
      description: REST surface for cluster.
      operations:
      - method: DELETE
        name: shutdowncluster
        description: Apache Flink Delete Cluster
        call: rest.shutdowncluster
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/config
      name: config
      description: REST surface for config.
      operations:
      - method: GET
        name: getdashboardconfiguration
        description: Apache Flink List Config
        call: rest.getdashboardconfiguration
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/datasets
      name: datasets
      description: REST surface for datasets.
      operations:
      - method: GET
        name: getclusterdatasetlist
        description: Apache Flink List Datasets
        call: rest.getclusterdatasetlist
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/datasets/delete/{triggerid}
      name: datasets-delete-triggerid
      description: REST surface for datasets-delete-triggerid.
      operations:
      - method: GET
        name: getclusterdatasetdeletestatus
        description: Apache Flink Get Datasets Delete
        call: rest.getclusterdatasetdeletestatus
        with:
          triggerid: rest.triggerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/datasets/{datasetid}
      name: datasets-datasetid
      description: REST surface for datasets-datasetid.
      operations:
      - method: DELETE
        name: deleteclusterdataset
        description: Apache Flink Delete Datasets
        call: rest.deleteclusterdataset
        with:
          datasetid: rest.datasetid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jars
      name: jars
      description: REST surface for jars.
      operations:
      - method: GET
        name: getjarlist
        description: Apache Flink List Jars
        call: rest.getjarlist
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jars/upload
      name: jars-upload
      description: REST surface for jars-upload.
      operations:
      - method: POST
        name: uploadjar
        description: Apache Flink Create Jars Upload
        call: rest.uploadjar
        with:
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jars/{jarid}
      name: jars-jarid
      description: REST surface for jars-jarid.
      operations:
      - method: DELETE
        name: deletejar
        description: Apache Flink Delete Jars
        call: rest.deletejar
        with:
          jarid: rest.jarid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jars/{jarid}/plan
      name: jars-jarid-plan
      description: REST surface for jars-jarid-plan.
      operations:
      - method: POST
        name: generateplanfromjar
        description: Apache Flink Create Jars Plan
        call: rest.generateplanfromjar
        with:
          jarid: rest.jarid
          programArg: rest.programArg
          entry-class: rest.entry-class
          parallelism: rest.parallelism
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jars/{jarid}/run
      name: jars-jarid-run
      description: REST surface for jars-jarid-run.
      operations:
      - method: POST
        name: submitjobfromjar
        description: Apache Flink Create Jars Run
        call: rest.submitjobfromjar
        with:
          jarid: rest.jarid
          allowNonRestoredState: rest.allowNonRestoredState
          savepointPath: rest.savepointPath
          programArg: rest.programArg
          entry-class: rest.entry-class
          parallelism: rest.parallelism
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobmanager/config
      name: jobmanager-config
      description: REST surface for jobmanager-config.
      operations:
      - method: GET
        name: getclusterconfigurationinfo
        description: Apache Flink List Jobmanager Config
        call: rest.getclusterconfigurationinfo
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobmanager/environment
      name: jobmanager-environment
      description: REST surface for jobmanager-environment.
      operations:
      - method: GET
        name: getjobmanagerenvironment
        description: Apache Flink List Jobmanager Environment
        call: rest.getjobmanagerenvironment
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobmanager/logs
      name: jobmanager-logs
      description: REST surface for jobmanager-logs.
      operations:
      - method: GET
        name: getjobmanagerloglist
        description: Apache Flink List Jobmanager Logs
        call: rest.getjobmanagerloglist
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobmanager/metrics
      name: jobmanager-metrics
      description: REST surface for jobmanager-metrics.
      operations:
      - method: GET
        name: getjobmanagermetrics
        description: Apache Flink List Jobmanager Metrics
        call: rest.getjobmanagermetrics
        with:
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobmanager/thread-dump
      name: jobmanager-thread-dump
      description: REST surface for jobmanager-thread-dump.
      operations:
      - method: GET
        name: getjobmanagerthreaddump
        description: Apache Flink List Jobmanager Thread-Dump
        call: rest.getjobmanagerthreaddump
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs
      name: jobs
      description: REST surface for jobs.
      operations:
      - method: GET
        name: getjobidswithstatusesoverview
        description: Apache Flink List Jobs
        call: rest.getjobidswithstatusesoverview
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/metrics
      name: jobs-metrics
      description: REST surface for jobs-metrics.
      operations:
      - method: GET
        name: getaggregatedjobmetrics
        description: Apache Flink List Jobs Metrics
        call: rest.getaggregatedjobmetrics
        with:
          get: rest.get
          agg: rest.agg
          jobs: rest.jobs
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/overview
      name: jobs-overview
      description: REST surface for jobs-overview.
      operations:
      - method: GET
        name: getjobsoverview
        description: Apache Flink List Jobs Overview
        call: rest.getjobsoverview
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}
      name: jobs-jobid
      description: REST surface for jobs-jobid.
      operations:
      - method: GET
        name: getjobdetails
        description: Apache Flink Get Jobs
        call: rest.getjobdetails
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
      - method: PATCH
        name: canceljob
        description: Apache Flink Update Jobs
        call: rest.canceljob
        with:
          jobid: rest.jobid
          mode: rest.mode
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/accumulators
      name: jobs-jobid-accumulators
      description: REST surface for jobs-jobid-accumulators.
      operations:
      - method: GET
        name: getjobaccumulators
        description: Apache Flink List Jobs Accumulators
        call: rest.getjobaccumulators
        with:
          jobid: rest.jobid
          includeSerializedValue: rest.includeSerializedValue
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/checkpoints
      name: jobs-jobid-checkpoints
      description: REST surface for jobs-jobid-checkpoints.
      operations:
      - method: GET
        name: getcheckpointingstatistics
        description: Apache Flink List Jobs Checkpoints
        call: rest.getcheckpointingstatistics
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
      - method: POST
        name: triggercheckpoint
        description: Apache Flink Create Jobs Checkpoints
        call: rest.triggercheckpoint
        with:
          jobid: rest.jobid
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/checkpoints/config
      name: jobs-jobid-checkpoints-config
      description: REST surface for jobs-jobid-checkpoints-config.
      operations:
      - method: GET
        name: getcheckpointconfig
        description: Apache Flink List Checkpoints Config
        call: rest.getcheckpointconfig
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/checkpoints/details/{checkpointid}
      name: jobs-jobid-checkpoints-details-checkpointid
      description: REST surface for jobs-jobid-checkpoints-details-checkpointid.
      operations:
      - method: GET
        name: getcheckpointstatisticdetails
        description: Apache Flink Get Checkpoints Details
        call: rest.getcheckpointstatisticdetails
        with:
          jobid: rest.jobid
          checkpointid: rest.checkpointid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/checkpoints/details/{checkpointid}/subtasks/{vertexid}
      name: jobs-jobid-checkpoints-details-checkpointid-subtasks-vertexid
      description: REST surface for jobs-jobid-checkpoints-details-checkpointid-subtasks-vertexid.
      operations:
      - method: GET
        name: gettaskcheckpointstatistics
        description: Apache Flink Get Details Subtasks
        call: rest.gettaskcheckpointstatistics
        with:
          jobid: rest.jobid
          checkpointid: rest.checkpointid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/checkpoints/{triggerid}
      name: jobs-jobid-checkpoints-triggerid
      description: REST surface for jobs-jobid-checkpoints-triggerid.
      operations:
      - method: GET
        name: getcheckpointstatus
        description: Apache Flink Get Jobs Checkpoints
        call: rest.getcheckpointstatus
        with:
          jobid: rest.jobid
          triggerid: rest.triggerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/clientheartbeat
      name: jobs-jobid-clientheartbeat
      description: REST surface for jobs-jobid-clientHeartbeat.
      operations:
      - method: PATCH
        name: triggerheartbeat
        description: Apache Flink Update Jobs Clientheartbeat
        call: rest.triggerheartbeat
        with:
          jobid: rest.jobid
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/config
      name: jobs-jobid-config
      description: REST surface for jobs-jobid-config.
      operations:
      - method: GET
        name: getjobconfig
        description: Apache Flink List Jobs Config
        call: rest.getjobconfig
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/exceptions
      name: jobs-jobid-exceptions
      description: REST surface for jobs-jobid-exceptions.
      operations:
      - method: GET
        name: getjobexceptions
        description: Apache Flink List Jobs Exceptions
        call: rest.getjobexceptions
        with:
          jobid: rest.jobid
          maxExceptions: rest.maxExceptions
          failureLabelFilter: rest.failureLabelFilter
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/execution-result
      name: jobs-jobid-execution-result
      description: REST surface for jobs-jobid-execution-result.
      operations:
      - method: GET
        name: getjobexecutionresult
        description: Apache Flink List Jobs Execution-Result
        call: rest.getjobexecutionresult
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/jobmanager/config
      name: jobs-jobid-jobmanager-config
      description: REST surface for jobs-jobid-jobmanager-config.
      operations:
      - method: GET
        name: getjobmanagerjobconfiguration
        description: Apache Flink List Jobmanager Config
        call: rest.getjobmanagerjobconfiguration
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/jobmanager/environment
      name: jobs-jobid-jobmanager-environment
      description: REST surface for jobs-jobid-jobmanager-environment.
      operations:
      - method: GET
        name: getjobmanagerjobenvironment
        description: Apache Flink List Jobmanager Environment
        call: rest.getjobmanagerjobenvironment
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/jobmanager/log-url
      name: jobs-jobid-jobmanager-log-url
      description: REST surface for jobs-jobid-jobmanager-log-url.
      operations:
      - method: GET
        name: getjobmanagerlogurl
        description: Apache Flink List Jobmanager Log-Url
        call: rest.getjobmanagerlogurl
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/metrics
      name: jobs-jobid-metrics
      description: REST surface for jobs-jobid-metrics.
      operations:
      - method: GET
        name: getjobmetrics
        description: Apache Flink List Jobs Metrics
        call: rest.getjobmetrics
        with:
          jobid: rest.jobid
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/plan
      name: jobs-jobid-plan
      description: REST surface for jobs-jobid-plan.
      operations:
      - method: GET
        name: getjobplan
        description: Apache Flink List Jobs Plan
        call: rest.getjobplan
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/rescaling
      name: jobs-jobid-rescaling
      description: REST surface for jobs-jobid-rescaling.
      operations:
      - method: PATCH
        name: rescalejob
        description: Apache Flink Update Jobs Rescaling
        call: rest.rescalejob
        with:
          jobid: rest.jobid
          parallelism: rest.parallelism
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/rescaling/{triggerid}
      name: jobs-jobid-rescaling-triggerid
      description: REST surface for jobs-jobid-rescaling-triggerid.
      operations:
      - method: GET
        name: getrescalingstatus
        description: Apache Flink Get Jobs Rescaling
        call: rest.getrescalingstatus
        with:
          jobid: rest.jobid
          triggerid: rest.triggerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/resource-requirements
      name: jobs-jobid-resource-requirements
      description: REST surface for jobs-jobid-resource-requirements.
      operations:
      - method: GET
        name: getjobresourcerequirements
        description: Apache Flink List Jobs Resource-Requirements
        call: rest.getjobresourcerequirements
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
      - method: PUT
        name: updatejobresourcerequirements
        description: Apache Flink Update Jobs Resource-Requirements
        call: rest.updatejobresourcerequirements
        with:
          jobid: rest.jobid
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/savepoints
      name: jobs-jobid-savepoints
      description: REST surface for jobs-jobid-savepoints.
      operations:
      - method: POST
        name: triggersavepoint
        description: Apache Flink Create Jobs Savepoints
        call: rest.triggersavepoint
        with:
          jobid: rest.jobid
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/savepoints/{triggerid}
      name: jobs-jobid-savepoints-triggerid
      description: REST surface for jobs-jobid-savepoints-triggerid.
      operations:
      - method: GET
        name: getsavepointstatus
        description: Apache Flink Get Jobs Savepoints
        call: rest.getsavepointstatus
        with:
          jobid: rest.jobid
          triggerid: rest.triggerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/status
      name: jobs-jobid-status
      description: REST surface for jobs-jobid-status.
      operations:
      - method: GET
        name: getjobstatusinfo
        description: Apache Flink List Jobs Status
        call: rest.getjobstatusinfo
        with:
          jobid: rest.jobid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/stop
      name: jobs-jobid-stop
      description: REST surface for jobs-jobid-stop.
      operations:
      - method: POST
        name: triggerstopwithsavepoint
        description: Apache Flink Create Jobs Stop
        call: rest.triggerstopwithsavepoint
        with:
          jobid: rest.jobid
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/taskmanagers/{taskmanagerid}/log-url
      name: jobs-jobid-taskmanagers-taskmanagerid-log-url
      description: REST surface for jobs-jobid-taskmanagers-taskmanagerid-log-url.
      operations:
      - method: GET
        name: gettaskmanagerlogurl
        description: Apache Flink List Taskmanagers Log-Url
        call: rest.gettaskmanagerlogurl
        with:
          jobid: rest.jobid
          taskmanagerid: rest.taskmanagerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}
      name: jobs-jobid-vertices-vertexid
      description: REST surface for jobs-jobid-vertices-vertexid.
      operations:
      - method: GET
        name: getjobvertexdetails
        description: Apache Flink Get Jobs Vertices
        call: rest.getjobvertexdetails
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/accumulators
      name: jobs-jobid-vertices-vertexid-accumulators
      description: REST surface for jobs-jobid-vertices-vertexid-accumulators.
      operations:
      - method: GET
        name: getjobvertexaccumulators
        description: Apache Flink List Vertices Accumulators
        call: rest.getjobvertexaccumulators
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/backpressure
      name: jobs-jobid-vertices-vertexid-backpressure
      description: REST surface for jobs-jobid-vertices-vertexid-backpressure.
      operations:
      - method: GET
        name: getjobvertexbackpressure
        description: Apache Flink List Vertices Backpressure
        call: rest.getjobvertexbackpressure
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/flamegraph
      name: jobs-jobid-vertices-vertexid-flamegraph
      description: REST surface for jobs-jobid-vertices-vertexid-flamegraph.
      operations:
      - method: GET
        name: getjobvertexflamegraph
        description: Apache Flink List Vertices Flamegraph
        call: rest.getjobvertexflamegraph
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          type: rest.type
          subtaskindex: rest.subtaskindex
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/jm-operator-metrics
      name: jobs-jobid-vertices-vertexid-jm-operator-metrics
      description: REST surface for jobs-jobid-vertices-vertexid-jm-operator-metrics.
      operations:
      - method: GET
        name: getjobmanageroperatormetrics
        description: Apache Flink List Vertices Jm-Operator-Metrics
        call: rest.getjobmanageroperatormetrics
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/metrics
      name: jobs-jobid-vertices-vertexid-metrics
      description: REST surface for jobs-jobid-vertices-vertexid-metrics.
      operations:
      - method: GET
        name: getjobvertexmetrics
        description: Apache Flink List Vertices Metrics
        call: rest.getjobvertexmetrics
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/accumulators
      name: jobs-jobid-vertices-vertexid-subtasks-accumulators
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-accumulators.
      operations:
      - method: GET
        name: getsubtasksallaccumulators
        description: Apache Flink List Subtasks Accumulators
        call: rest.getsubtasksallaccumulators
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/metrics
      name: jobs-jobid-vertices-vertexid-subtasks-metrics
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-metrics.
      operations:
      - method: GET
        name: getaggregatedsubtaskmetrics
        description: Apache Flink List Subtasks Metrics
        call: rest.getaggregatedsubtaskmetrics
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          get: rest.get
          agg: rest.agg
          subtasks: rest.subtasks
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}
      name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-subtaskindex.
      operations:
      - method: GET
        name: getsubtaskcurrentattemptdetails
        description: Apache Flink Get Vertices Subtasks
        call: rest.getsubtaskcurrentattemptdetails
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          subtaskindex: rest.subtaskindex
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}
      name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt.
      operations:
      - method: GET
        name: getsubtaskexecutionattemptdetails
        description: Apache Flink Get Subtasks Attempts
        call: rest.getsubtaskexecutionattemptdetails
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          subtaskindex: rest.subtaskindex
          attempt: rest.attempt
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}/accumulators
      name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt-accumulators
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-subtaskindex-attempts-attempt-accumulators.
      operations:
      - method: GET
        name: getsubtaskexecutionattemptaccumulators
        description: Apache Flink List Attempts Accumulators
        call: rest.getsubtaskexecutionattemptaccumulators
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          subtaskindex: rest.subtaskindex
          attempt: rest.attempt
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/metrics
      name: jobs-jobid-vertices-vertexid-subtasks-subtaskindex-metrics
      description: REST surface for jobs-jobid-vertices-vertexid-subtasks-subtaskindex-metrics.
      operations:
      - method: GET
        name: getsubtaskmetrics
        description: Apache Flink List Subtasks Metrics
        call: rest.getsubtaskmetrics
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
          subtaskindex: rest.subtaskindex
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/subtasktimes
      name: jobs-jobid-vertices-vertexid-subtasktimes
      description: REST surface for jobs-jobid-vertices-vertexid-subtasktimes.
      operations:
      - method: GET
        name: getsubtaskstimes
        description: Apache Flink List Vertices Subtasktimes
        call: rest.getsubtaskstimes
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/taskmanagers
      name: jobs-jobid-vertices-vertexid-taskmanagers
      description: REST surface for jobs-jobid-vertices-vertexid-taskmanagers.
      operations:
      - method: GET
        name: getjobvertextaskmanagers
        description: Apache Flink List Vertices Taskmanagers
        call: rest.getjobvertextaskmanagers
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/jobs/{jobid}/vertices/{vertexid}/watermarks
      name: jobs-jobid-vertices-vertexid-watermarks
      description: REST surface for jobs-jobid-vertices-vertexid-watermarks.
      operations:
      - method: GET
        name: getjobvertexwatermarks
        description: Apache Flink List Vertices Watermarks
        call: rest.getjobvertexwatermarks
        with:
          jobid: rest.jobid
          vertexid: rest.vertexid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/overview
      name: overview
      description: REST surface for overview.
      operations:
      - method: GET
        name: getclusteroverview
        description: Apache Flink List Overview
        call: rest.getclusteroverview
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/savepoint-disposal
      name: savepoint-disposal
      description: REST surface for savepoint-disposal.
      operations:
      - method: POST
        name: triggersavepointdisposal
        description: Apache Flink Create Savepoint-Disposal
        call: rest.triggersavepointdisposal
        with:
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/savepoint-disposal/{triggerid}
      name: savepoint-disposal-triggerid
      description: REST surface for savepoint-disposal-triggerid.
      operations:
      - method: GET
        name: getsavepointdisposalstatus
        description: Apache Flink Get Savepoint-Disposal
        call: rest.getsavepointdisposalstatus
        with:
          triggerid: rest.triggerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers
      name: taskmanagers
      description: REST surface for taskmanagers.
      operations:
      - method: GET
        name: gettaskmanagers
        description: Apache Flink List Taskmanagers
        call: rest.gettaskmanagers
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers/metrics
      name: taskmanagers-metrics
      description: REST surface for taskmanagers-metrics.
      operations:
      - method: GET
        name: getaggregatedtaskmanagermetrics
        description: Apache Flink List Taskmanagers Metrics
        call: rest.getaggregatedtaskmanagermetrics
        with:
          get: rest.get
          agg: rest.agg
          taskmanagers: rest.taskmanagers
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers/{taskmanagerid}
      name: taskmanagers-taskmanagerid
      description: REST surface for taskmanagers-taskmanagerid.
      operations:
      - method: GET
        name: gettaskmanagerdetails
        description: Apache Flink Get Taskmanagers
        call: rest.gettaskmanagerdetails
        with:
          taskmanagerid: rest.taskmanagerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers/{taskmanagerid}/logs
      name: taskmanagers-taskmanagerid-logs
      description: REST surface for taskmanagers-taskmanagerid-logs.
      operations:
      - method: GET
        name: gettaskmanagerlogs
        description: Apache Flink List Taskmanagers Logs
        call: rest.gettaskmanagerlogs
        with:
          taskmanagerid: rest.taskmanagerid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers/{taskmanagerid}/metrics
      name: taskmanagers-taskmanagerid-metrics
      description: REST surface for taskmanagers-taskmanagerid-metrics.
      operations:
      - method: GET
        name: gettaskmanagermetrics
        description: Apache Flink List Taskmanagers Metrics
        call: rest.gettaskmanagermetrics
        with:
          taskmanagerid: rest.taskmanagerid
          get: rest.get
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/taskmanagers/{taskmanagerid}/thread-dump
      name: taskmanagers-taskmanagerid-thread-dump
      description: REST surface for taskmanagers-taskmanagerid-thread-dump.
      operations:
      - method: GET
        name: gettaskmanagerthreaddump
        description: Apache Flink List Taskmanagers Thread-Dump
        call: rest.gettaskmanagerthreaddump
        with:
          taskmanagerid: rest.taskmanagerid
        outputParameters:
        - type: object
          mapping: $.
  - type: mcp
    namespace: rest-mcp
    port: 9090
    transport: http
    description: MCP adapter for Flink JobManager REST API. One tool per consumed operation, routed inline through this capability's
      consumes block.
    tools:
    - name: apache-flink-delete-cluster
      description: Apache Flink Delete Cluster
      hints:
        readOnly: false
        destructive: true
        idempotent: true
      call: rest.shutdowncluster
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-config
      description: Apache Flink List Config
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getdashboardconfiguration
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-datasets
      description: Apache Flink List Datasets
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getclusterdatasetlist
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-datasets-delete
      description: Apache Flink Get Datasets Delete
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getclusterdatasetdeletestatus
      with:
        triggerid: tools.triggerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-delete-datasets
      description: Apache Flink Delete Datasets
      hints:
        readOnly: false
        destructive: true
        idempotent: true
      call: rest.deleteclusterdataset
      with:
        datasetid: tools.datasetid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jars
      description: Apache Flink List Jars
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjarlist
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jars-upload
      description: Apache Flink Create Jars Upload
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.uploadjar
      with:
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-delete-jars
      description: Apache Flink Delete Jars
      hints:
        readOnly: false
        destructive: true
        idempotent: true
      call: rest.deletejar
      with:
        jarid: tools.jarid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jars-plan
      description: Apache Flink Create Jars Plan
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.generateplanfromjar
      with:
        jarid: tools.jarid
        programArg: tools.programArg
        entry-class: tools.entry-class
        parallelism: tools.parallelism
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jars-run
      description: Apache Flink Create Jars Run
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.submitjobfromjar
      with:
        jarid: tools.jarid
        allowNonRestoredState: tools.allowNonRestoredState
        savepointPath: tools.savepointPath
        programArg: tools.programArg
        entry-class: tools.entry-class
        parallelism: tools.parallelism
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-config
      description: Apache Flink List Jobmanager Config
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getclusterconfigurationinfo
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-environment
      description: Apache Flink List Jobmanager Environment
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerenvironment
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-logs
      description: Apache Flink List Jobmanager Logs
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerloglist
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-metrics
      description: Apache Flink List Jobmanager Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagermetrics
      with:
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-thread
      description: Apache Flink List Jobmanager Thread-Dump
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerthreaddump
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs
      description: Apache Flink List Jobs
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobidswithstatusesoverview
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-metrics
      description: Apache Flink List Jobs Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getaggregatedjobmetrics
      with:
        get: tools.get
        agg: tools.agg
        jobs: tools.jobs
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-overview
      description: Apache Flink List Jobs Overview
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobsoverview
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-jobs
      description: Apache Flink Get Jobs
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobdetails
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-update-jobs
      description: Apache Flink Update Jobs
      hints:
        readOnly: false
        destructive: false
        idempotent: true
      call: rest.canceljob
      with:
        jobid: tools.jobid
        mode: tools.mode
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-accumulators
      description: Apache Flink List Jobs Accumulators
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobaccumulators
      with:
        jobid: tools.jobid
        includeSerializedValue: tools.includeSerializedValue
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-checkpoints
      description: Apache Flink List Jobs Checkpoints
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getcheckpointingstatistics
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jobs-checkpoints
      description: Apache Flink Create Jobs Checkpoints
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.triggercheckpoint
      with:
        jobid: tools.jobid
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-checkpoints-config
      description: Apache Flink List Checkpoints Config
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getcheckpointconfig
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-checkpoints-details
      description: Apache Flink Get Checkpoints Details
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getcheckpointstatisticdetails
      with:
        jobid: tools.jobid
        checkpointid: tools.checkpointid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-details-subtasks
      description: Apache Flink Get Details Subtasks
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskcheckpointstatistics
      with:
        jobid: tools.jobid
        checkpointid: tools.checkpointid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-jobs-checkpoints
      description: Apache Flink Get Jobs Checkpoints
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getcheckpointstatus
      with:
        jobid: tools.jobid
        triggerid: tools.triggerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-update-jobs-clientheartbeat
      description: Apache Flink Update Jobs Clientheartbeat
      hints:
        readOnly: false
        destructive: false
        idempotent: true
      call: rest.triggerheartbeat
      with:
        jobid: tools.jobid
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-config
      description: Apache Flink List Jobs Config
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobconfig
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-exceptions
      description: Apache Flink List Jobs Exceptions
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobexceptions
      with:
        jobid: tools.jobid
        maxExceptions: tools.maxExceptions
        failureLabelFilter: tools.failureLabelFilter
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-execution
      description: Apache Flink List Jobs Execution-Result
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobexecutionresult
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-config-2
      description: Apache Flink List Jobmanager Config
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerjobconfiguration
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-environment-2
      description: Apache Flink List Jobmanager Environment
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerjobenvironment
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobmanager-log
      description: Apache Flink List Jobmanager Log-Url
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanagerlogurl
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-metrics-2
      description: Apache Flink List Jobs Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmetrics
      with:
        jobid: tools.jobid
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-plan
      description: Apache Flink List Jobs Plan
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobplan
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-update-jobs-rescaling
      description: Apache Flink Update Jobs Rescaling
      hints:
        readOnly: false
        destructive: false
        idempotent: true
      call: rest.rescalejob
      with:
        jobid: tools.jobid
        parallelism: tools.parallelism
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-jobs-rescaling
      description: Apache Flink Get Jobs Rescaling
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getrescalingstatus
      with:
        jobid: tools.jobid
        triggerid: tools.triggerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-resource
      description: Apache Flink List Jobs Resource-Requirements
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobresourcerequirements
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-update-jobs-resource
      description: Apache Flink Update Jobs Resource-Requirements
      hints:
        readOnly: false
        destructive: false
        idempotent: true
      call: rest.updatejobresourcerequirements
      with:
        jobid: tools.jobid
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jobs-savepoints
      description: Apache Flink Create Jobs Savepoints
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.triggersavepoint
      with:
        jobid: tools.jobid
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-jobs-savepoints
      description: Apache Flink Get Jobs Savepoints
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsavepointstatus
      with:
        jobid: tools.jobid
        triggerid: tools.triggerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-jobs-status
      description: Apache Flink List Jobs Status
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobstatusinfo
      with:
        jobid: tools.jobid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-jobs-stop
      description: Apache Flink Create Jobs Stop
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.triggerstopwithsavepoint
      with:
        jobid: tools.jobid
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers-log
      description: Apache Flink List Taskmanagers Log-Url
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagerlogurl
      with:
        jobid: tools.jobid
        taskmanagerid: tools.taskmanagerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-jobs-vertices
      description: Apache Flink Get Jobs Vertices
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexdetails
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-accumulators
      description: Apache Flink List Vertices Accumulators
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexaccumulators
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-backpressure
      description: Apache Flink List Vertices Backpressure
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexbackpressure
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-flamegraph
      description: Apache Flink List Vertices Flamegraph
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexflamegraph
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        type: tools.type
        subtaskindex: tools.subtaskindex
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-jm
      description: Apache Flink List Vertices Jm-Operator-Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobmanageroperatormetrics
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-metrics
      description: Apache Flink List Vertices Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexmetrics
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-subtasks-accumulators
      description: Apache Flink List Subtasks Accumulators
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtasksallaccumulators
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-subtasks-metrics
      description: Apache Flink List Subtasks Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getaggregatedsubtaskmetrics
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        get: tools.get
        agg: tools.agg
        subtasks: tools.subtasks
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-vertices-subtasks
      description: Apache Flink Get Vertices Subtasks
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtaskcurrentattemptdetails
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        subtaskindex: tools.subtaskindex
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-subtasks-attempts
      description: Apache Flink Get Subtasks Attempts
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtaskexecutionattemptdetails
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        subtaskindex: tools.subtaskindex
        attempt: tools.attempt
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-attempts-accumulators
      description: Apache Flink List Attempts Accumulators
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtaskexecutionattemptaccumulators
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        subtaskindex: tools.subtaskindex
        attempt: tools.attempt
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-subtasks-metrics-2
      description: Apache Flink List Subtasks Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtaskmetrics
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
        subtaskindex: tools.subtaskindex
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-subtasktimes
      description: Apache Flink List Vertices Subtasktimes
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsubtaskstimes
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-taskmanagers
      description: Apache Flink List Vertices Taskmanagers
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertextaskmanagers
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-vertices-watermarks
      description: Apache Flink List Vertices Watermarks
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getjobvertexwatermarks
      with:
        jobid: tools.jobid
        vertexid: tools.vertexid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-overview
      description: Apache Flink List Overview
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getclusteroverview
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-create-savepoint-disposal
      description: Apache Flink Create Savepoint-Disposal
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: rest.triggersavepointdisposal
      with:
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-savepoint-disposal
      description: Apache Flink Get Savepoint-Disposal
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getsavepointdisposalstatus
      with:
        triggerid: tools.triggerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers
      description: Apache Flink List Taskmanagers
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagers
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers-metrics
      description: Apache Flink List Taskmanagers Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.getaggregatedtaskmanagermetrics
      with:
        get: tools.get
        agg: tools.agg
        taskmanagers: tools.taskmanagers
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-get-taskmanagers
      description: Apache Flink Get Taskmanagers
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagerdetails
      with:
        taskmanagerid: tools.taskmanagerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers-logs
      description: Apache Flink List Taskmanagers Logs
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagerlogs
      with:
        taskmanagerid: tools.taskmanagerid
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers-metrics-2
      description: Apache Flink List Taskmanagers Metrics
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagermetrics
      with:
        taskmanagerid: tools.taskmanagerid
        get: tools.get
      outputParameters:
      - type: object
        mapping: $.
    - name: apache-flink-list-taskmanagers-thread
      description: Apache Flink List Taskmanagers Thread-Dump
      hints:
        readOnly: true
        destructive: false
        idempotent: true
      call: rest.gettaskmanagerthreaddump
      with:
        taskmanagerid: tools.taskmanagerid
      outputParameters:
      - type: object
        mapping: $.