Apache Flink · Agentic Access
Apache Flink Agentic Access

x-agentic-access generated
Apache Flink exposes 69 API operations that an AI agent could call, of which 14 are state-changing ‘acting’ operations. This is a recommended x-agentic-access execution contract — the scope, audience, consequence tier, short-lived token constraints, and escalation each action should carry before it is handed to an autonomous agent.
By consequence: 55 read, 12 write, and 2 safety-critical.
2 operations are classed safety-critical and should require human-in-the-loop approval at runtime.
Contracts are classified heuristically from the provider’s OpenAPI and refresh on every APIs.io network build; audience is bound per deployment. The model follows Curity’s Access Intelligence (apidays Munich 2026). Browse every provider’s agent contracts at agentic-access.apis.io.
ApacheBatch ProcessingBig DataOpen SourceReal-Time AnalyticsStateful ComputingStream Processing
Operations: 69 Acting: 14 Human-in-the-loop: 2 Method: generated
By consequence

read 55 write 12 safety-critical 2
Highest-consequence actions

The physical and safety-critical operations an agent could invoke — the ones that most warrant scoped tokens, tight TTLs, and escalation. Full per-operation contracts are in the source below.
Method	Path	Consequence	Human-in-loop
DELETE	/cluster	safety-critical	required
POST	/jobs/{jobid}/stop	safety-critical	required
Source

Agentic Access

generated: '2026-07-15'
method: generated
source: openapi/apache-flink-rest-openapi-original.yml
description: Recommended x-agentic-access execution contracts, classified heuristically from
  the OpenAPI. A governance starting point for exposing this API to AI agents — review and bind
  audience per deployment. See research/curity/agentic-governance/.
summary:
  operations: 69
  by_action_class:
    acting: 14
    connected: 55
  by_consequence:
    safety-critical: 2
    read: 55
    write: 12
  human_in_the_loop_required: 2
operations:
- path: /cluster
  method: delete
  operationId: shutdownCluster
  x-agentic-access:
    action-class: acting
    consequence: safety-critical
    subject: required
    audience: null
    token:
      max-ttl: 120
      exchange: true
      purpose-required: true
      proof-of-possession: true
    escalation:
      human-in-the-loop: required
    audit: required
- path: /config
  method: get
  operationId: getDashboardConfiguration
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /datasets
  method: get
  operationId: getClusterDataSetList
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /datasets/delete/{triggerid}
  method: get
  operationId: getClusterDataSetDeleteStatus
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /datasets/{datasetid}
  method: delete
  operationId: deleteClusterDataSet
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jars
  method: get
  operationId: getJarList
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jars/upload
  method: post
  operationId: uploadJar
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jars/{jarid}
  method: delete
  operationId: deleteJar
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jars/{jarid}/plan
  method: post
  operationId: generatePlanFromJar
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jars/{jarid}/run
  method: post
  operationId: submitJobFromJar
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobmanager/config
  method: get
  operationId: getClusterConfigurationInfo
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobmanager/environment
  method: get
  operationId: getJobManagerEnvironment
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobmanager/logs
  method: get
  operationId: getJobManagerLogList
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobmanager/metrics
  method: get
  operationId: getJobManagerMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobmanager/thread-dump
  method: get
  operationId: getJobManagerThreadDump
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs
  method: get
  operationId: getJobIdsWithStatusesOverview
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/metrics
  method: get
  operationId: getAggregatedJobMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/overview
  method: get
  operationId: getJobsOverview
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}
  method: get
  operationId: getJobDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}
  method: patch
  operationId: cancelJob
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/accumulators
  method: get
  operationId: getJobAccumulators
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/checkpoints
  method: get
  operationId: getCheckpointingStatistics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/checkpoints
  method: post
  operationId: triggerCheckpoint
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/checkpoints/config
  method: get
  operationId: getCheckpointConfig
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/checkpoints/details/{checkpointid}
  method: get
  operationId: getCheckpointStatisticDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/checkpoints/details/{checkpointid}/subtasks/{vertexid}
  method: get
  operationId: getTaskCheckpointStatistics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/checkpoints/{triggerid}
  method: get
  operationId: getCheckpointStatus
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/clientHeartbeat
  method: patch
  operationId: triggerHeartbeat
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/config
  method: get
  operationId: getJobConfig
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/exceptions
  method: get
  operationId: getJobExceptions
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/execution-result
  method: get
  operationId: getJobExecutionResult
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/jobmanager/config
  method: get
  operationId: getJobManagerJobConfiguration
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/jobmanager/environment
  method: get
  operationId: getJobManagerJobEnvironment
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/jobmanager/log-url
  method: get
  operationId: getJobManagerLogUrl
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/metrics
  method: get
  operationId: getJobMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/plan
  method: get
  operationId: getJobPlan
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/rescaling
  method: patch
  operationId: rescaleJob
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/rescaling/{triggerid}
  method: get
  operationId: getRescalingStatus
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/resource-requirements
  method: get
  operationId: getJobResourceRequirements
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/resource-requirements
  method: put
  operationId: updateJobResourceRequirements
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/savepoints
  method: post
  operationId: triggerSavepoint
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /jobs/{jobid}/savepoints/{triggerid}
  method: get
  operationId: getSavepointStatus
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/status
  method: get
  operationId: getJobStatusInfo
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/stop
  method: post
  operationId: triggerStopWithSavepoint
  x-agentic-access:
    action-class: acting
    consequence: safety-critical
    subject: required
    audience: null
    token:
      max-ttl: 120
      exchange: true
      purpose-required: true
      proof-of-possession: true
    escalation:
      human-in-the-loop: required
    audit: required
- path: /jobs/{jobid}/taskmanagers/{taskmanagerid}/log-url
  method: get
  operationId: getTaskManagerLogUrl
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}
  method: get
  operationId: getJobVertexDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/accumulators
  method: get
  operationId: getJobVertexAccumulators
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/backpressure
  method: get
  operationId: getJobVertexBackPressure
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/flamegraph
  method: get
  operationId: getJobVertexFlameGraph
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/jm-operator-metrics
  method: get
  operationId: getJobManagerOperatorMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/metrics
  method: get
  operationId: getJobVertexMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/accumulators
  method: get
  operationId: getSubtasksAllAccumulators
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/metrics
  method: get
  operationId: getAggregatedSubtaskMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}
  method: get
  operationId: getSubtaskCurrentAttemptDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}
  method: get
  operationId: getSubtaskExecutionAttemptDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/attempts/{attempt}/accumulators
  method: get
  operationId: getSubtaskExecutionAttemptAccumulators
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasks/{subtaskindex}/metrics
  method: get
  operationId: getSubtaskMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/subtasktimes
  method: get
  operationId: getSubtasksTimes
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/taskmanagers
  method: get
  operationId: getJobVertexTaskManagers
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /jobs/{jobid}/vertices/{vertexid}/watermarks
  method: get
  operationId: getJobVertexWatermarks
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /overview
  method: get
  operationId: getClusterOverview
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /savepoint-disposal
  method: post
  operationId: triggerSavepointDisposal
  x-agentic-access:
    action-class: acting
    consequence: write
    subject: required
    audience: null
    token:
      max-ttl: 900
    escalation:
      human-in-the-loop: conditional
      triggers:
      - abnormal
      - high-value
    audit: required
- path: /savepoint-disposal/{triggerid}
  method: get
  operationId: getSavepointDisposalStatus
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers
  method: get
  operationId: getTaskManagers
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers/metrics
  method: get
  operationId: getAggregatedTaskManagerMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers/{taskmanagerid}
  method: get
  operationId: getTaskManagerDetails
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers/{taskmanagerid}/logs
  method: get
  operationId: getTaskManagerLogs
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers/{taskmanagerid}/metrics
  method: get
  operationId: getTaskManagerMetrics
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none
- path: /taskmanagers/{taskmanagerid}/thread-dump
  method: get
  operationId: getTaskManagerThreadDump
  x-agentic-access:
    action-class: connected
    consequence: read
    subject: optional
    token:
      max-ttl: 3600
    audit: none