Apache Flink website screenshot

Apache Flink

Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. It provides a REST API for job management, cluster operations, metrics collection, and checkpoint management for real-time streaming and batch processing workloads.

Apache Flink publishes 9 APIs on the APIs.io network, including Cluster API, Config API, Datasets API, and 6 more. Tagged areas include Apache, Batch Processing, Big Data, Open-Source, and Real-Time Analytics.

The Apache Flink catalog on APIs.io includes 1 JSON-LD context and 2 Spectral governance rulesets.

Apache Flink’s developer surface includes getting-started guide, engineering blog, support, training material, Stack Overflow tag, and 12 more developer resources.

🌐 Visit website 📡 Source on GitHub
30.8/100 thin ▬ flat Agent 19/100 agent aware self hosted · Apache-2.0 Full breakdown ↓
scored 2026-09-08 · rubric v0.20.0
AccessFreemium
1 APIs 9 Features 5 Use Cases
ApacheBatch ProcessingBig DataOpen-SourceReal-Time AnalyticsStateful ComputingStream Processing

Kin Score

Kin Score Kin Score How this is scored →
scored 2026-09-08 · rubric v0.20.0
Composite quality — 30.8/100 · thin
Contract Quality 10.6 / 20
Developer Ergonomics 2.7 / 16
Access Clarity 2.5 / 16
Operational Transparency 1.1 / 10
Contract Governance 2.8 / 10
Discoverability 4.7 / 8
Open Source Surface 4.0 / 10
Create-or-Update Ergonomics 0.0 / 10
Agent readiness — 19/100 · agent aware
Machine-Readable Contract 18 / 18
Agentic Access Contract 10 / 10
Documented Reversibility 6 / 6
MCP Server 0 / 12
Machine-Readable Auth 0 / 10
Idempotency 0 / 9
Stable Error Semantics 0 / 8
Request/Response Examples 0 / 7
Rate-Limit Signaling 7 / 7
Typed Event Surface 0 / 6
Agent Skills 0 / 5
Well-Known Catalog 0 / 4
Consent & Bot Identity 0 / 3
A2A Agent Card 0 / 8
Dry-Run / Simulate Mode 0 / 4
Delegated User Identity 0 / 6
Protected Resource Metadata 0 / 5
Registration Without a Human 0 / 6
Agentic Commerce Well-Known Document 0 / 5
Open Source Surface applies to this provider. This product is open source and we read its repository directly, so Open Source Surface carries 10 points of the composite. It is scored from what the repository actually publishes — a security policy, a contribution guide, a release history, a code of conduct — read live from the provider rather than inferred from our own catalog pointers. This facet adds; nothing was taken away to make room for it. An open-source project is not excused from the commercial facets, because exemption would strip it of the points it does earn. If we have the wrong repository, or this product is not open source, say so on your provider repo and we will drop the facet rather than have you publish against it.
Create-or-Update Ergonomics applies to this provider. This API accepts writes, so it carries 10 points of the composite. It is scored from the published contracts themselves: whether a caller can create-or-update in one call, whether the write accepts a key the caller already holds, and whether the response says which branch ran. Without that, every write needs a search-and-branch in front of it, and the first time that check is skipped a duplicate record is created. Scored against the observed mean rather than raw — a provider at the catalog average is unchanged by this facet, not penalised by it.
The six quality facets above are damped to 80 points between them, because the conditional facet above carries the other 20. That is why each facet's contribution is shown against a damped maximum: raising a quality facet moves the composite by 80% of its nominal weight, not 100%. The full arithmetic is at apis.io/rating/.
Improve this rating by publishing the missing artifacts — every area above can be raised, and the full rubric is at apis.io/rating/. Every facet and dimension name above is a link: it opens that measurement's own page — what it means, the exact checks that feed it, how the whole catalog distributes on it, and the providers at the top of it. This rating is computed from github.com/api-evangelist/apache-flink: open an issue to ask a question, or submit a pull request to add artifacts. Submit an artifact on GitHub — free → Manage your own listing — the Influence plan, $499/mo →

APIs 10

Individual APIs this provider publishes, each with its own machine-readable definition.

Apache Flink Monitoring API

Monitoring REST API for accessing job metrics, checkpoints, and cluster statistics for Apache Flink deployments.

Apache Flink Cluster API

The Cluster API from Apache Flink — 1 operation(s) for cluster.

Apache Flink Config API

The Config API from Apache Flink — 1 operation(s) for config.

Apache Flink Datasets API

The Datasets API from Apache Flink — 3 operation(s) for datasets.

Apache Flink Jars API

The Jars API from Apache Flink — 5 operation(s) for jars.

Apache Flink Jobmanager API

The Jobmanager API from Apache Flink — 5 operation(s) for jobmanager.

Apache Flink Jobs API

The Jobs API from Apache Flink — 42 operation(s) for jobs.

Apache Flink Overview API

The Overview API from Apache Flink — 1 operation(s) for overview.

Apache Flink Savepoint Disposal API

The Savepoint Disposal API from Apache Flink — 2 operation(s) for savepoint disposal.

Apache Flink Taskmanagers API

The Taskmanagers API from Apache Flink — 6 operation(s) for taskmanagers.

Scroll for all 10

Open Collections 10

Open, tool-agnostic API collections (OpenAPI-derived and Bruno).

API Collection

OPEN COLLECTION

Flink JobManager REST Cluster API

OPEN COLLECTION

Flink JobManager REST Cluster Config API

OPEN COLLECTION

Flink JobManager REST Cluster Datasets API

OPEN COLLECTION

Flink JobManager REST Cluster Jars API

OPEN COLLECTION

Flink REST Cluster Jobmanager API

OPEN COLLECTION

Flink JobManager REST Cluster Jobs API

OPEN COLLECTION

Flink JobManager REST Cluster Overview API

OPEN COLLECTION

Flink JobManager REST Cluster Savepoint Disposal API

OPEN COLLECTION

Flink JobManager REST Cluster Taskmanagers API

OPEN COLLECTION

Scroll for all 10

Pricing Plans 1

Published pricing tiers and plan structures.

Apache Flink Plans Pricing

3 plans

PLANS

Rate Limits 1

Documented rate limits and quota policies.

Apache Flink Rate Limits

5 limits

RATE LIMITS

FinOps 1

Cost, billing, and metering signals for API financial operations.

Apache Flink Finops

FINOPS

Features 9

Notable capabilities this provider offers.

Unified Stream and Batch Processing

Single engine for both unbounded stream processing and bounded batch workloads with a unified API.

Stateful Computations

Rich stateful processing with managed state backends (RocksDB, heap), exactly-once guarantees, and state versioning.

Exactly-Once Semantics

End-to-end exactly-once processing guarantees with distributed snapshots and transactional sinks.

Event Time Processing

Native event-time support with watermarks for out-of-order event handling in streaming workloads.

Checkpointing and Savepoints

Automatic fault-tolerance via checkpointing and manual savepoints for job migration and upgrades.

High Availability

JobManager HA via ZooKeeper or Kubernetes for zero-downtime cluster operations.

Scalable Architecture

Horizontally scalable TaskManagers with fine-grained resource management and dynamic slot allocation.

REST API Management

Comprehensive REST API for job submission, monitoring, metrics collection, and cluster administration.

SQL and Table API

Declarative SQL and Table API for streaming analytics with connector ecosystem support.

Scroll for all 9

Semantic Vocabularies 1

JSON-LD contexts and semantic vocabularies used across these APIs.

Apache Flink Rest Context

52 classes · 130 properties

JSON-LD

Spectral Rules 2

Spectral governance rulesets for linting and validating these APIs.

Apache Flink API Rules

5 rules · 3 warnings 2 info

SPECTRAL

Apache Flink API Rules

16 rules · 5 errors 9 warnings 2 info

SPECTRAL

JSON Schema 132

Standalone JSON Schema definitions for this provider's data models.

AggregatedMetricsResponseBody

0 properties

JSON SCHEMA

AggregatedTaskDetailsInfo

2 properties

JSON SCHEMA

AggregationMode

0 properties

JSON SCHEMA

ApplicationStatus

0 properties

JSON SCHEMA

AsynchronousOperationInfo

1 properties

JSON SCHEMA

AsynchronousOperationResult

2 properties

JSON SCHEMA

CheckpointAlignment

4 properties

JSON SCHEMA

CheckpointAlignmentSummary

4 properties

JSON SCHEMA

CheckpointConfigInfo

15 properties

JSON SCHEMA

CheckpointDuration

2 properties

JSON SCHEMA

CheckpointDurationSummary

2 properties

JSON SCHEMA

CheckpointInfo

2 properties

JSON SCHEMA

CheckpointStatistics

17 properties

JSON SCHEMA

CheckpointStatisticsSummary

6 properties

JSON SCHEMA

CheckpointStatsStatus

0 properties

JSON SCHEMA

CheckpointTriggerRequestBody

2 properties

JSON SCHEMA

CheckpointType

0 properties

JSON SCHEMA

CheckpointingStatistics

4 properties

JSON SCHEMA

ClusterDataSetEntry

2 properties

JSON SCHEMA

ClusterDataSetListResponseBody

1 properties

JSON SCHEMA

ClusterOverviewWithVersion

11 properties

JSON SCHEMA

CompletedCheckpointStatistics

0 properties

JSON SCHEMA

CompletedSubtaskCheckpointStatistics

0 properties

JSON SCHEMA

ConfigurationInfoEntry

2 properties

JSON SCHEMA

ConfigurationInfo

0 properties

JSON SCHEMA

Counts

5 properties

JSON SCHEMA

DashboardConfiguration

6 properties

JSON SCHEMA

EnvironmentInfo

2 properties

JSON SCHEMA

ExceptionInfo

7 properties

JSON SCHEMA

ExecutionConfigInfo

4 properties

JSON SCHEMA

ExecutionState

0 properties

JSON SCHEMA

ExternalizedCheckpointInfo

2 properties

JSON SCHEMA

FailedCheckpointStatistics

0 properties

JSON SCHEMA

FailureLabel

2 properties

JSON SCHEMA

Features

4 properties

JSON SCHEMA

GarbageCollectorInfo

3 properties

JSON SCHEMA

HardwareDescription

4 properties

JSON SCHEMA

Id

0 properties

JSON SCHEMA

IntermediateDataSetID

0 properties

JSON SCHEMA

IOMetricsInfo

11 properties

JSON SCHEMA

JarEntryInfo

2 properties

JSON SCHEMA

JarFileInfo

4 properties

JSON SCHEMA

JarListInfo

2 properties

JSON SCHEMA

JarPlanRequestBody

5 properties

JSON SCHEMA

JarRunRequestBody

9 properties

JSON SCHEMA

JarRunResponseBody

1 properties

JSON SCHEMA

JarUploadResponseBody

2 properties

JSON SCHEMA

JobAccumulator

0 properties

JSON SCHEMA

JobAccumulatorsInfo

3 properties

JSON SCHEMA

JobClientHeartbeatRequestBody

1 properties

JSON SCHEMA

JobConfigInfo

3 properties

JSON SCHEMA

JobDetailsInfo

16 properties

JSON SCHEMA

JobDetails

9 properties

JSON SCHEMA

JobDetailsVertexInfo

11 properties

JSON SCHEMA

JobExceptionHistory

2 properties

JSON SCHEMA

JobExceptionsInfoWithHistory

1 properties

JSON SCHEMA

JobExecutionResultResponseBody

2 properties

JSON SCHEMA

JobID

0 properties

JSON SCHEMA

JobIdWithStatus

2 properties

JSON SCHEMA

JobIdsWithStatusOverview

1 properties

JSON SCHEMA

JobPlanInfo

1 properties

JSON SCHEMA

JobResourceRequirementsBody

0 properties

JSON SCHEMA

JobResult

6 properties

JSON SCHEMA

JobStatusInfo

1 properties

JSON SCHEMA

JobStatus

0 properties

JSON SCHEMA

JobType

0 properties

JSON SCHEMA

JobVertexAccumulatorsInfo

2 properties

JSON SCHEMA

JobVertexBackPressureInfo

4 properties

JSON SCHEMA

JobVertexDetailsInfo

7 properties

JSON SCHEMA

JobVertexID

0 properties

JSON SCHEMA

JobVertexResourceRequirements

1 properties

JSON SCHEMA

JobVertexTaskManagerInfo

9 properties

JSON SCHEMA

JobVertexTaskManagersInfo

4 properties

JSON SCHEMA

JVMInfo

3 properties

JSON SCHEMA

LatestCheckpoints

4 properties

JSON SCHEMA

LogInfo

3 properties

JSON SCHEMA

LogListInfo

1 properties

JSON SCHEMA

LogUrlResponse

1 properties

JSON SCHEMA

MetricCollectionResponseBody

1 properties

JSON SCHEMA

Metric

2 properties

JSON SCHEMA

MultipleJobsDetails

1 properties

JSON SCHEMA

Node

3 properties

JSON SCHEMA

Parallelism

2 properties

JSON SCHEMA

PendingCheckpointStatistics

0 properties

JSON SCHEMA

PendingSubtaskCheckpointStatistics

0 properties

JSON SCHEMA

ProcessingMode

0 properties

JSON SCHEMA

QueueStatus

1 properties

JSON SCHEMA

RawJson

0 properties

JSON SCHEMA

RecoveryClaimMode

0 properties

JSON SCHEMA

ResourceID

0 properties

JSON SCHEMA

ResourceProfileInfo

6 properties

JSON SCHEMA

RestAPICheckpointType

0 properties

JSON SCHEMA

RestoredCheckpointStatistics

4 properties

JSON SCHEMA

RootExceptionInfo

8 properties

JSON SCHEMA

SavepointDisposalRequest

1 properties

JSON SCHEMA

SavepointFormatType

0 properties

JSON SCHEMA

SavepointInfo

2 properties

JSON SCHEMA

SavepointTriggerRequestBody

4 properties

JSON SCHEMA

SerializedThrowable

1 properties

JSON SCHEMA

SerializedValueOptionalFailureObject

1 properties

JSON SCHEMA

SlotInfo

2 properties

JSON SCHEMA

SlotSharingGroupId

3 properties

JSON SCHEMA

StatsSummaryDto

8 properties

JSON SCHEMA

StopWithSavepointRequestBody

4 properties

JSON SCHEMA

SubtaskAccumulatorsInfo

4 properties

JSON SCHEMA

SubtaskBackPressureInfo

7 properties

JSON SCHEMA

SubtaskCheckpointStatistics

3 properties

JSON SCHEMA

SubtaskExecutionAttemptAccumulatorsInfo

4 properties

JSON SCHEMA

SubtaskExecutionAttemptDetailsInfo

11 properties

JSON SCHEMA

SubtaskTimeInfo

4 properties

JSON SCHEMA

SubtasksAllAccumulatorsInfo

3 properties

JSON SCHEMA

SubtasksTimesInfo

4 properties

JSON SCHEMA

TaskCheckpointStatistics

11 properties

JSON SCHEMA

TaskCheckpointStatisticsWithSubtaskDetails

13 properties

JSON SCHEMA

TaskCheckpointStatisticsWithSubtaskDetailsSummary

6 properties

JSON SCHEMA

TaskExecutorMemoryConfiguration

10 properties

JSON SCHEMA

TaskManagerDetailsInfo

14 properties

JSON SCHEMA

TaskManagerInfo

12 properties

JSON SCHEMA

TaskManagerMetricsInfo

19 properties

JSON SCHEMA

TaskManagersInfo

1 properties

JSON SCHEMA

TerminationMode

0 properties

JSON SCHEMA

ThreadDumpInfo

1 properties

JSON SCHEMA

ThreadInfo

2 properties

JSON SCHEMA

ThreadStates

0 properties

JSON SCHEMA

TriggerId

0 properties

JSON SCHEMA

TriggerResponse

1 properties

JSON SCHEMA

UploadStatus

0 properties

JSON SCHEMA

UserAccumulator

3 properties

JSON SCHEMA

UserTaskAccumulator

3 properties

JSON SCHEMA

VertexBackPressureLevel

0 properties

JSON SCHEMA

VertexBackPressureStatus

0 properties

JSON SCHEMA

VertexFlameGraph

2 properties

JSON SCHEMA

Scroll for all 132

JSON Structure 132

JSON Structure definitions describing this provider's data shapes.

Flink Rest Aggregated Metrics Response Body Structure

0 properties

JSON STRUCTURE

Flink Rest Aggregated Task Details Info Structure

2 properties

JSON STRUCTURE

Flink Rest Aggregation Mode Structure

0 properties

JSON STRUCTURE

Flink Rest Application Status Structure

0 properties

JSON STRUCTURE

Flink Rest Asynchronous Operation Info Structure

1 properties

JSON STRUCTURE

Flink Rest Asynchronous Operation Result Structure

2 properties

JSON STRUCTURE

Flink Rest Checkpoint Alignment Structure

4 properties

JSON STRUCTURE

Flink Rest Checkpoint Alignment Summary Structure

4 properties

JSON STRUCTURE

Flink Rest Checkpoint Config Info Structure

15 properties

JSON STRUCTURE

Flink Rest Checkpoint Duration Structure

2 properties

JSON STRUCTURE

Flink Rest Checkpoint Duration Summary Structure

2 properties

JSON STRUCTURE

Flink Rest Checkpoint Info Structure

2 properties

JSON STRUCTURE

Flink Rest Checkpoint Statistics Structure

17 properties

JSON STRUCTURE

Flink Rest Checkpoint Statistics Summary Structure

6 properties

JSON STRUCTURE

Flink Rest Checkpoint Stats Status Structure

0 properties

JSON STRUCTURE

Flink Rest Checkpoint Trigger Request Body Structure

2 properties

JSON STRUCTURE

Flink Rest Checkpoint Type Structure

0 properties

JSON STRUCTURE

Flink Rest Checkpointing Statistics Structure

4 properties

JSON STRUCTURE

Flink Rest Cluster Data Set Entry Structure

2 properties

JSON STRUCTURE

Flink Rest Cluster Data Set List Response Body Structure

1 properties

JSON STRUCTURE

Flink Rest Cluster Overview With Version Structure

11 properties

JSON STRUCTURE

Flink Rest Completed Checkpoint Statistics Structure

0 properties

JSON STRUCTURE

Flink Rest Completed Subtask Checkpoint Statistics Structure

0 properties

JSON STRUCTURE

Flink Rest Configuration Info Entry Structure

2 properties

JSON STRUCTURE

Flink Rest Configuration Info Structure

0 properties

JSON STRUCTURE

Flink Rest Counts Structure

5 properties

JSON STRUCTURE

Flink Rest Dashboard Configuration Structure

6 properties

JSON STRUCTURE

Flink Rest Environment Info Structure

2 properties

JSON STRUCTURE

Flink Rest Exception Info Structure

7 properties

JSON STRUCTURE

Flink Rest Execution Config Info Structure

4 properties

JSON STRUCTURE

Flink Rest Execution State Structure

0 properties

JSON STRUCTURE

Flink Rest Externalized Checkpoint Info Structure

2 properties

JSON STRUCTURE

Flink Rest Failed Checkpoint Statistics Structure

0 properties

JSON STRUCTURE

Flink Rest Failure Label Structure

2 properties

JSON STRUCTURE

Flink Rest Features Structure

4 properties

JSON STRUCTURE

Flink Rest Garbage Collector Info Structure

3 properties

JSON STRUCTURE

Flink Rest Hardware Description Structure

4 properties

JSON STRUCTURE

Flink Rest Id Structure

0 properties

JSON STRUCTURE

Flink Rest Intermediate Data Set Id Structure

0 properties

JSON STRUCTURE

Flink Rest Io Metrics Info Structure

11 properties

JSON STRUCTURE

Flink Rest Jar Entry Info Structure

2 properties

JSON STRUCTURE

Flink Rest Jar File Info Structure

4 properties

JSON STRUCTURE

Flink Rest Jar List Info Structure

2 properties

JSON STRUCTURE

Flink Rest Jar Plan Request Body Structure

5 properties

JSON STRUCTURE

Flink Rest Jar Run Request Body Structure

9 properties

JSON STRUCTURE

Flink Rest Jar Run Response Body Structure

1 properties

JSON STRUCTURE

Flink Rest Jar Upload Response Body Structure

2 properties

JSON STRUCTURE

Flink Rest Job Accumulator Structure

0 properties

JSON STRUCTURE

Flink Rest Job Accumulators Info Structure

3 properties

JSON STRUCTURE

Flink Rest Job Client Heartbeat Request Body Structure

1 properties

JSON STRUCTURE

Flink Rest Job Config Info Structure

3 properties

JSON STRUCTURE

Flink Rest Job Details Info Structure

16 properties

JSON STRUCTURE

Flink Rest Job Details Structure

9 properties

JSON STRUCTURE

Flink Rest Job Details Vertex Info Structure

11 properties

JSON STRUCTURE

Flink Rest Job Exception History Structure

2 properties

JSON STRUCTURE

Flink Rest Job Exceptions Info With History Structure

1 properties

JSON STRUCTURE

Flink Rest Job Execution Result Response Body Structure

2 properties

JSON STRUCTURE

Flink Rest Job Id Structure

0 properties

JSON STRUCTURE

Flink Rest Job Id With Status Structure

2 properties

JSON STRUCTURE

Flink Rest Job Ids With Status Overview Structure

1 properties

JSON STRUCTURE

Flink Rest Job Plan Info Structure

1 properties

JSON STRUCTURE

Flink Rest Job Resource Requirements Body Structure

0 properties

JSON STRUCTURE

Flink Rest Job Result Structure

6 properties

JSON STRUCTURE

Flink Rest Job Status Info Structure

1 properties

JSON STRUCTURE

Flink Rest Job Status Structure

0 properties

JSON STRUCTURE

Flink Rest Job Type Structure

0 properties

JSON STRUCTURE

Flink Rest Job Vertex Accumulators Info Structure

2 properties

JSON STRUCTURE

Flink Rest Job Vertex Back Pressure Info Structure

4 properties

JSON STRUCTURE

Flink Rest Job Vertex Details Info Structure

7 properties

JSON STRUCTURE

Flink Rest Job Vertex Id Structure

0 properties

JSON STRUCTURE

Flink Rest Job Vertex Resource Requirements Structure

1 properties

JSON STRUCTURE

Flink Rest Job Vertex Task Manager Info Structure

9 properties

JSON STRUCTURE

Flink Rest Job Vertex Task Managers Info Structure

4 properties

JSON STRUCTURE

Flink Rest Jvm Info Structure

3 properties

JSON STRUCTURE

Flink Rest Latest Checkpoints Structure

4 properties

JSON STRUCTURE

Flink Rest Log Info Structure

3 properties

JSON STRUCTURE

Flink Rest Log List Info Structure

1 properties

JSON STRUCTURE

Flink Rest Log Url Response Structure

1 properties

JSON STRUCTURE

Flink Rest Metric Collection Response Body Structure

1 properties

JSON STRUCTURE

Flink Rest Metric Structure

2 properties

JSON STRUCTURE

Flink Rest Multiple Jobs Details Structure

1 properties

JSON STRUCTURE

Flink Rest Node Structure

3 properties

JSON STRUCTURE

Flink Rest Parallelism Structure

2 properties

JSON STRUCTURE

Flink Rest Pending Checkpoint Statistics Structure

0 properties

JSON STRUCTURE

Flink Rest Pending Subtask Checkpoint Statistics Structure

0 properties

JSON STRUCTURE

Flink Rest Processing Mode Structure

0 properties

JSON STRUCTURE

Flink Rest Queue Status Structure

1 properties

JSON STRUCTURE

Flink Rest Raw Json Structure

0 properties

JSON STRUCTURE

Flink Rest Recovery Claim Mode Structure

0 properties

JSON STRUCTURE

Flink Rest Resource Id Structure

0 properties

JSON STRUCTURE

Flink Rest Resource Profile Info Structure

6 properties

JSON STRUCTURE

Flink Rest Rest Api Checkpoint Type Structure

0 properties

JSON STRUCTURE

Flink Rest Restored Checkpoint Statistics Structure

4 properties

JSON STRUCTURE

Flink Rest Root Exception Info Structure

8 properties

JSON STRUCTURE

Flink Rest Savepoint Disposal Request Structure

1 properties

JSON STRUCTURE

Flink Rest Savepoint Format Type Structure

0 properties

JSON STRUCTURE

Flink Rest Savepoint Info Structure

2 properties

JSON STRUCTURE

Flink Rest Savepoint Trigger Request Body Structure

4 properties

JSON STRUCTURE

Flink Rest Serialized Throwable Structure

1 properties

JSON STRUCTURE

Flink Rest Serialized Value Optional Failure Object Structure

1 properties

JSON STRUCTURE

Flink Rest Slot Info Structure

2 properties

JSON STRUCTURE

Flink Rest Slot Sharing Group Id Structure

3 properties

JSON STRUCTURE

Flink Rest Stats Summary Dto Structure

8 properties

JSON STRUCTURE

Flink Rest Stop With Savepoint Request Body Structure

4 properties

JSON STRUCTURE

Flink Rest Subtask Accumulators Info Structure

4 properties

JSON STRUCTURE

Flink Rest Subtask Back Pressure Info Structure

7 properties

JSON STRUCTURE

Flink Rest Subtask Checkpoint Statistics Structure

3 properties

JSON STRUCTURE

Flink Rest Subtask Execution Attempt Accumulators Info Structure

4 properties

JSON STRUCTURE

Flink Rest Subtask Execution Attempt Details Info Structure

11 properties

JSON STRUCTURE

Flink Rest Subtask Time Info Structure

4 properties

JSON STRUCTURE

Flink Rest Subtasks All Accumulators Info Structure

3 properties

JSON STRUCTURE

Flink Rest Subtasks Times Info Structure

4 properties

JSON STRUCTURE

Flink Rest Task Checkpoint Statistics Structure

11 properties

JSON STRUCTURE

Flink Rest Task Checkpoint Statistics With Subtask Details Structure

13 properties

JSON STRUCTURE

Flink Rest Task Checkpoint Statistics With Subtask Details Summary Structure

6 properties

JSON STRUCTURE

Flink Rest Task Executor Memory Configuration Structure

10 properties

JSON STRUCTURE

Flink Rest Task Manager Details Info Structure

14 properties

JSON STRUCTURE

Flink Rest Task Manager Info Structure

12 properties

JSON STRUCTURE

Flink Rest Task Manager Metrics Info Structure

19 properties

JSON STRUCTURE

Flink Rest Task Managers Info Structure

1 properties

JSON STRUCTURE

Flink Rest Termination Mode Structure

0 properties

JSON STRUCTURE

Flink Rest Thread Dump Info Structure

1 properties

JSON STRUCTURE

Flink Rest Thread Info Structure

2 properties

JSON STRUCTURE

Flink Rest Thread States Structure

0 properties

JSON STRUCTURE

Flink Rest Trigger Id Structure

0 properties

JSON STRUCTURE

Flink Rest Trigger Response Structure

1 properties

JSON STRUCTURE

Flink Rest Upload Status Structure

0 properties

JSON STRUCTURE

Flink Rest User Accumulator Structure

3 properties

JSON STRUCTURE

Flink Rest User Task Accumulator Structure

3 properties

JSON STRUCTURE

Flink Rest Vertex Back Pressure Level Structure

0 properties

JSON STRUCTURE

Flink Rest Vertex Back Pressure Status Structure

0 properties

JSON STRUCTURE

Flink Rest Vertex Flame Graph Structure

2 properties

JSON STRUCTURE

Scroll for all 132

Examples 132

Example request and response payloads for these APIs.

Flink Rest Aggregated Metrics Response Body Example

0 fields

EXAMPLE

Flink Rest Aggregated Task Details Info Example

2 fields

EXAMPLE

Flink Rest Aggregation Mode Example

0 fields

EXAMPLE

Flink Rest Application Status Example

0 fields

EXAMPLE

Flink Rest Asynchronous Operation Info Example

1 fields

EXAMPLE

Flink Rest Asynchronous Operation Result Example

2 fields

EXAMPLE

Flink Rest Checkpoint Alignment Example

4 fields

EXAMPLE

Flink Rest Checkpoint Alignment Summary Example

4 fields

EXAMPLE

Flink Rest Checkpoint Config Info Example

15 fields

EXAMPLE

Flink Rest Checkpoint Duration Example

2 fields

EXAMPLE

Flink Rest Checkpoint Duration Summary Example

2 fields

EXAMPLE

Flink Rest Checkpoint Info Example

2 fields

EXAMPLE

Flink Rest Checkpoint Statistics Example

17 fields

EXAMPLE

Flink Rest Checkpoint Statistics Summary Example

6 fields

EXAMPLE

Flink Rest Checkpoint Stats Status Example

0 fields

EXAMPLE

Flink Rest Checkpoint Trigger Request Body Example

2 fields

EXAMPLE

Flink Rest Checkpoint Type Example

0 fields

EXAMPLE

Flink Rest Checkpointing Statistics Example

4 fields

EXAMPLE

Flink Rest Cluster Data Set Entry Example

2 fields

EXAMPLE

Flink Rest Cluster Data Set List Response Body Example

1 fields

EXAMPLE

Flink Rest Cluster Overview With Version Example

11 fields

EXAMPLE

Flink Rest Completed Checkpoint Statistics Example

0 fields

EXAMPLE

Flink Rest Completed Subtask Checkpoint Statistics Example

0 fields

EXAMPLE

Flink Rest Configuration Info Entry Example

2 fields

EXAMPLE

Flink Rest Configuration Info Example

0 fields

EXAMPLE

Flink Rest Counts Example

5 fields

EXAMPLE

Flink Rest Dashboard Configuration Example

6 fields

EXAMPLE

Flink Rest Environment Info Example

2 fields

EXAMPLE

Flink Rest Exception Info Example

7 fields

EXAMPLE

Flink Rest Execution Config Info Example

4 fields

EXAMPLE

Flink Rest Execution State Example

0 fields

EXAMPLE

Flink Rest Externalized Checkpoint Info Example

2 fields

EXAMPLE

Flink Rest Failed Checkpoint Statistics Example

0 fields

EXAMPLE

Flink Rest Failure Label Example

2 fields

EXAMPLE

Flink Rest Features Example

4 fields

EXAMPLE

Flink Rest Garbage Collector Info Example

3 fields

EXAMPLE

Flink Rest Hardware Description Example

4 fields

EXAMPLE

Flink Rest Id Example

0 fields

EXAMPLE

Flink Rest Intermediate Data Set Id Example

0 fields

EXAMPLE

Flink Rest Io Metrics Info Example

11 fields

EXAMPLE

Flink Rest Jar Entry Info Example

2 fields

EXAMPLE

Flink Rest Jar File Info Example

4 fields

EXAMPLE

Flink Rest Jar List Info Example

2 fields

EXAMPLE

Flink Rest Jar Plan Request Body Example

5 fields

EXAMPLE

Flink Rest Jar Run Request Body Example

9 fields

EXAMPLE

Flink Rest Jar Run Response Body Example

1 fields

EXAMPLE

Flink Rest Jar Upload Response Body Example

2 fields

EXAMPLE

Flink Rest Job Accumulator Example

0 fields

EXAMPLE

Flink Rest Job Accumulators Info Example

3 fields

EXAMPLE

Flink Rest Job Client Heartbeat Request Body Example

1 fields

EXAMPLE

Flink Rest Job Config Info Example

3 fields

EXAMPLE

Flink Rest Job Details Example

9 fields

EXAMPLE

Flink Rest Job Details Info Example

16 fields

EXAMPLE

Flink Rest Job Details Vertex Info Example

11 fields

EXAMPLE

Flink Rest Job Exception History Example

2 fields

EXAMPLE

Flink Rest Job Exceptions Info With History Example

1 fields

EXAMPLE

Flink Rest Job Execution Result Response Body Example

2 fields

EXAMPLE

Flink Rest Job Id Example

0 fields

EXAMPLE

Flink Rest Job Id With Status Example

2 fields

EXAMPLE

Flink Rest Job Ids With Status Overview Example

1 fields

EXAMPLE

Flink Rest Job Plan Info Example

1 fields

EXAMPLE

Flink Rest Job Resource Requirements Body Example

0 fields

EXAMPLE

Flink Rest Job Result Example

6 fields

EXAMPLE

Flink Rest Job Status Example

0 fields

EXAMPLE

Flink Rest Job Status Info Example

1 fields

EXAMPLE

Flink Rest Job Type Example

0 fields

EXAMPLE

Flink Rest Job Vertex Accumulators Info Example

2 fields

EXAMPLE

Flink Rest Job Vertex Back Pressure Info Example

4 fields

EXAMPLE

Flink Rest Job Vertex Details Info Example

7 fields

EXAMPLE

Flink Rest Job Vertex Id Example

0 fields

EXAMPLE

Flink Rest Job Vertex Resource Requirements Example

1 fields

EXAMPLE

Flink Rest Job Vertex Task Manager Info Example

9 fields

EXAMPLE

Flink Rest Job Vertex Task Managers Info Example

4 fields

EXAMPLE

Flink Rest Jvm Info Example

3 fields

EXAMPLE

Flink Rest Latest Checkpoints Example

4 fields

EXAMPLE

Flink Rest Log Info Example

3 fields

EXAMPLE

Flink Rest Log List Info Example

1 fields

EXAMPLE

Flink Rest Log Url Response Example

1 fields

EXAMPLE

Flink Rest Metric Collection Response Body Example

1 fields

EXAMPLE

Flink Rest Metric Example

2 fields

EXAMPLE

Flink Rest Multiple Jobs Details Example

1 fields

EXAMPLE

Flink Rest Node Example

3 fields

EXAMPLE

Flink Rest Parallelism Example

2 fields

EXAMPLE

Flink Rest Pending Checkpoint Statistics Example

0 fields

EXAMPLE

Flink Rest Pending Subtask Checkpoint Statistics Example

0 fields

EXAMPLE

Flink Rest Processing Mode Example

0 fields

EXAMPLE

Flink Rest Queue Status Example

1 fields

EXAMPLE

Flink Rest Raw Json Example

0 fields

EXAMPLE

Flink Rest Recovery Claim Mode Example

0 fields

EXAMPLE

Flink Rest Resource Id Example

0 fields

EXAMPLE

Flink Rest Resource Profile Info Example

6 fields

EXAMPLE

Flink Rest Rest Api Checkpoint Type Example

0 fields

EXAMPLE

Flink Rest Restored Checkpoint Statistics Example

4 fields

EXAMPLE

Flink Rest Root Exception Info Example

8 fields

EXAMPLE

Flink Rest Savepoint Disposal Request Example

1 fields

EXAMPLE

Flink Rest Savepoint Format Type Example

0 fields

EXAMPLE

Flink Rest Savepoint Info Example

2 fields

EXAMPLE

Flink Rest Savepoint Trigger Request Body Example

4 fields

EXAMPLE

Flink Rest Serialized Throwable Example

1 fields

EXAMPLE

Flink Rest Serialized Value Optional Failure Object Example

1 fields

EXAMPLE

Flink Rest Slot Info Example

2 fields

EXAMPLE

Flink Rest Slot Sharing Group Id Example

3 fields

EXAMPLE

Flink Rest Stats Summary Dto Example

8 fields

EXAMPLE

Flink Rest Stop With Savepoint Request Body Example

4 fields

EXAMPLE

Flink Rest Subtask Accumulators Info Example

4 fields

EXAMPLE

Flink Rest Subtask Back Pressure Info Example

7 fields

EXAMPLE

Flink Rest Subtask Checkpoint Statistics Example

3 fields

EXAMPLE

Flink Rest Subtask Execution Attempt Accumulators Info Example

4 fields

EXAMPLE

Flink Rest Subtask Execution Attempt Details Info Example

11 fields

EXAMPLE

Flink Rest Subtask Time Info Example

4 fields

EXAMPLE

Flink Rest Subtasks All Accumulators Info Example

3 fields

EXAMPLE

Flink Rest Subtasks Times Info Example

4 fields

EXAMPLE

Flink Rest Task Checkpoint Statistics Example

11 fields

EXAMPLE

Flink Rest Task Checkpoint Statistics With Subtask Details Example

13 fields

EXAMPLE

Flink Rest Task Checkpoint Statistics With Subtask Details Summary Example

6 fields

EXAMPLE

Flink Rest Task Executor Memory Configuration Example

10 fields

EXAMPLE

Flink Rest Task Manager Details Info Example

14 fields

EXAMPLE

Flink Rest Task Manager Info Example

12 fields

EXAMPLE

Flink Rest Task Manager Metrics Info Example

19 fields

EXAMPLE

Flink Rest Task Managers Info Example

1 fields

EXAMPLE

Flink Rest Termination Mode Example

0 fields

EXAMPLE

Flink Rest Thread Dump Info Example

1 fields

EXAMPLE

Flink Rest Thread Info Example

2 fields

EXAMPLE

Flink Rest Thread States Example

0 fields

EXAMPLE

Flink Rest Trigger Id Example

0 fields

EXAMPLE

Flink Rest Trigger Response Example

1 fields

EXAMPLE

Flink Rest Upload Status Example

0 fields

EXAMPLE

Flink Rest User Accumulator Example

3 fields

EXAMPLE

Flink Rest User Task Accumulator Example

3 fields

EXAMPLE

Flink Rest Vertex Back Pressure Level Example

0 fields

EXAMPLE

Flink Rest Vertex Back Pressure Status Example

0 fields

EXAMPLE

Flink Rest Vertex Flame Graph Example

2 fields

EXAMPLE

Scroll for all 132

Security Posture 2

Authentication, domain security, vulnerability disclosure, and trust-center signals.

Apache Flink Domain Security

TLSv1.3 · DMARC

SECURITY

Apache Flink Vulnerability Disclosure

security.txt · contact published

SECURITY

Agentic Access 1

Recommended x-agentic-access execution contracts for AI agents.

Apache Flink Agentic Access

69 operations · 14 acting · 2 human-in-the-loop

69 operations · 14 acting

AGENTIC

Use Cases 5

What developers build with this provider.

Real-Time Analytics

Process and analyze event streams in real time for dashboards, alerts, and operational intelligence.

ETL Pipelines

Build scalable ETL pipelines for data lake ingestion, transformation, and enrichment.

Fraud Detection

Detect fraudulent transactions in real time using stateful pattern matching over event streams.

IoT Data Processing

Process high-volume IoT device telemetry with stateful aggregations and time-window computations.

Machine Learning Inference

Serve ML model predictions at scale with streaming feature computation and online inference.

Integrations 7

Pre-built integrations with other platforms and tools.

Apache Kafka

Kafka source and sink connectors for high-throughput event streaming ingestion and output.

Apache Hadoop / HDFS

HDFS integration for batch data reading and writing in distributed storage.

Apache Hive

Hive catalog integration and batch SQL queries over Hive tables.

Kubernetes

Native Kubernetes deployment with FlinkDeployment CRD and the Flink Kubernetes Operator.

Apache Iceberg

Iceberg table format integration for lakehouse workloads with ACID guarantees.

Elasticsearch

Elasticsearch sink connector for real-time search index updates from Flink jobs.

Amazon Kinesis

Kinesis source and sink connectors for AWS-native streaming pipelines.

Scroll for all 7

Resources

Get Started 1

Portal, sign-up, and the first successful call

GettingStarted
GettingStarted

Documentation 1

Reference material describing how the API behaves

ContributionGuide
ContributionGuide

Agent Surfaces 1

MCP servers, agent skills, and machine-readable catalogs

AgenticAccess
AgenticAccess

Design & Contract 2

Pagination, idempotency, versioning, errors, and events

SpectralRules
SpectralRules
 Vocabulary
Vocabulary

Build 3

SDKs, sample code, and the tooling you integrate with

CodeOfConduct
CodeOfConduct
 GitHubOrganization
GitHubOrganization
 GitHubRepository
GitHubRepository

Access & Security 2

Authentication, authorization, and security posture

VulnerabilityDisclosure
VulnerabilityDisclosure
 DomainSecurity
DomainSecurity

Learn 1

Tutorials, courses, talks, and written guidance

Training
Training

Operate 2

Status, limits, changes, and where to get help

Support
Support
 StackOverflow
StackOverflow

Commercial 1

Pricing, plans, and the legal terms of use

License
License

Company 2

The organization behind the API

Website
Website
 Blog
Blog

Other 1

Properties that don't map to a standard resource type

X
X

Source (apis.yml)

apis.yml Raw ↑ 
aid: apache-flink
name: Apache Flink
description: Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded
  data streams. It provides a REST API for job management, cluster operations, metrics collection, and checkpoint management
  for real-time streaming and batch processing workloads.
type: Index
deliveryModel:
  model: self-hosted
  license: Apache-2.0
  open_source: true
  commercial: false
  callable_host: false
  label: Self-hosted open source · you run it yourself
  confidence: high
  source:
  - license
  - openapi
  generated: '2026-08-28'
  method: derived
accessModel:
  pricing: freemium
  onboarding: unknown
  trial: false
  try_now: false
  public: false
  label: Freemium
  confidence: medium
  source:
  - plans
  generated: '2026-07-22'
  method: derived
image: https://kinlane-images.s3.amazonaws.com/shared/apis-json/icons/apache-flink.png
tags:
- Apache
- Batch Processing
- Big Data
- Open-Source
- Real-Time Analytics
- Stateful Computing
- Stream Processing
tags_raw:
- Apache
- Batch Processing
- Big Data
- Open Source
- Real-Time Analytics
- Stateful Computing
- Stream Processing
url: https://raw.githubusercontent.com/api-evangelist/apache-flink/refs/heads/main/apis.yml
created: '2024-01-01'
modified: '2026-05-19'
specificationVersion: '0.23'
apis:
- aid: apache-flink:apache-flink-monitoring
  name: Apache Flink Monitoring API
  description: Monitoring REST API for accessing job metrics, checkpoints, and cluster statistics for Apache Flink deployments.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/monitoring/
  baseURL: http://localhost:8081
  tags:
  - Metrics
  - Monitoring
  - Observability
  properties:
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/monitoring/
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/metrics/
    title: Metrics Reference
- aid: apache-flink:apache-flink-cluster-api
  name: Apache Flink Cluster API
  description: The Cluster API from Apache Flink — 1 operation(s) for cluster.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Cluster
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-cluster-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-config-api
  name: Apache Flink Config API
  description: The Config API from Apache Flink — 1 operation(s) for config.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Config
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-config-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-datasets-api
  name: Apache Flink Datasets API
  description: The Datasets API from Apache Flink — 3 operation(s) for datasets.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Datasets
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-datasets-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-jars-api
  name: Apache Flink Jars API
  description: The Jars API from Apache Flink — 5 operation(s) for jars.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - JARs
  tags_raw:
  - Jars
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-jars-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-jobmanager-api
  name: Apache Flink Jobmanager API
  description: The Jobmanager API from Apache Flink — 5 operation(s) for jobmanager.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - JobManager
  tags_raw:
  - Jobmanager
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-jobmanager-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-jobs-api
  name: Apache Flink Jobs API
  description: The Jobs API from Apache Flink — 42 operation(s) for jobs.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Job
  tags_raw:
  - Jobs
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-jobs-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-overview-api
  name: Apache Flink Overview API
  description: The Overview API from Apache Flink — 1 operation(s) for overview.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Overview
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-overview-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-savepoint-disposal-api
  name: Apache Flink Savepoint Disposal API
  description: The Savepoint Disposal API from Apache Flink — 2 operation(s) for savepoint disposal.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - Savepoint Disposal
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-savepoint-disposal-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
- aid: apache-flink:apache-flink-taskmanagers-api
  name: Apache Flink Taskmanagers API
  description: The Taskmanagers API from Apache Flink — 6 operation(s) for taskmanagers.
  humanURL: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  baseURL: http://localhost:8081
  tags:
  - TaskManagers
  tags_raw:
  - Taskmanagers
  properties:
  - type: OpenAPI
    url: openapi/apache-flink-taskmanagers-api-openapi.yml
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/
  - type: JSONSchema
    url: json-schema/flink-rest-job-details-info-schema.json
  - type: JSONLD
    url: json-ld/apache-flink-rest-context.jsonld
common:
- type: Website
  url: https://www.apache.org/
- type: CodeOfConduct
  url: https://github.com/apache/.github/blob/main/.github/CODE_OF_CONDUCT.md
- type: ContributionGuide
  url: https://github.com/apache/flink/blob/master/.github/CONTRIBUTING.md
- type: License
  name: Apache-2.0
  url: https://github.com/apache/flink/blob/master/LICENSE
- type: AgenticAccess
  url: agentic-access/apache-flink-agentic-access.yml
- type: VulnerabilityDisclosure
  url: security/apache-flink-vulnerability-disclosure.yml
- type: DomainSecurity
  url: security/apache-flink-domain-security.yml
- type: GettingStarted
  url: https://nightlies.apache.org/flink/flink-docs-stable/docs/try-flink/local_installation/
- type: GitHubOrganization
  url: https://github.com/apache
- type: GitHubRepository
  url: https://github.com/apache/flink
- type: Blog
  url: https://flink.apache.org/blog/
- type: Support
  url: https://flink.apache.org/community.html
- type: Training
  url: https://nightlies.apache.org/flink/flink-docs-stable/docs/learn-flink/overview/
- type: StackOverflow
  url: https://stackoverflow.com/questions/tagged/apache-flink
- type: X
  url: https://twitter.com/apacheflink
- type: SpectralRules
  url: rules/apache-flink-spectral-rules.yml
- type: Vocabulary
  url: vocabulary/apache-flink-vocabulary.yaml
- type: Features
  data:
  - name: Unified Stream and Batch Processing
    description: Single engine for both unbounded stream processing and bounded batch workloads with a unified API.
  - name: Stateful Computations
    description: Rich stateful processing with managed state backends (RocksDB, heap), exactly-once guarantees, and state
      versioning.
  - name: Exactly-Once Semantics
    description: End-to-end exactly-once processing guarantees with distributed snapshots and transactional sinks.
  - name: Event Time Processing
    description: Native event-time support with watermarks for out-of-order event handling in streaming workloads.
  - name: Checkpointing and Savepoints
    description: Automatic fault-tolerance via checkpointing and manual savepoints for job migration and upgrades.
  - name: High Availability
    description: JobManager HA via ZooKeeper or Kubernetes for zero-downtime cluster operations.
  - name: Scalable Architecture
    description: Horizontally scalable TaskManagers with fine-grained resource management and dynamic slot allocation.
  - name: REST API Management
    description: Comprehensive REST API for job submission, monitoring, metrics collection, and cluster administration.
  - name: SQL and Table API
    description: Declarative SQL and Table API for streaming analytics with connector ecosystem support.
- type: UseCases
  data:
  - name: Real-Time Analytics
    description: Process and analyze event streams in real time for dashboards, alerts, and operational intelligence.
  - name: ETL Pipelines
    description: Build scalable ETL pipelines for data lake ingestion, transformation, and enrichment.
  - name: Fraud Detection
    description: Detect fraudulent transactions in real time using stateful pattern matching over event streams.
  - name: IoT Data Processing
    description: Process high-volume IoT device telemetry with stateful aggregations and time-window computations.
  - name: Machine Learning Inference
    description: Serve ML model predictions at scale with streaming feature computation and online inference.
- type: Integrations
  data:
  - name: Apache Kafka
    description: Kafka source and sink connectors for high-throughput event streaming ingestion and output.
  - name: Apache Hadoop / HDFS
    description: HDFS integration for batch data reading and writing in distributed storage.
  - name: Apache Hive
    description: Hive catalog integration and batch SQL queries over Hive tables.
  - name: Kubernetes
    description: Native Kubernetes deployment with FlinkDeployment CRD and the Flink Kubernetes Operator.
  - name: Apache Iceberg
    description: Iceberg table format integration for lakehouse workloads with ACID guarantees.
  - name: Elasticsearch
    description: Elasticsearch sink connector for real-time search index updates from Flink jobs.
  - name: Amazon Kinesis
    description: Kinesis source and sink connectors for AWS-native streaming pipelines.
maintainers:
- FN: Apache Software Foundation
  email: user@flink.apache.org

Work with this as data

Every provider here is available over the APIs.io API and to AI agents over MCP.

MCP server

One button, every client — Claude, Cursor, VS Code and the rest.

https://apis.io/mcp

Tools for providers

9 MCP tools reach this
  • find_providersBrowse and filter every provider in the catalog.
  • get_provider_artifactsEvery artifact this provider publishes, grouped by type.
  • get_provider_operationsEvery operation across all of their OpenAPIs — one call instead of parsing every spec.
  • get_provider_toolsEvery MCP tool they ship, with the operation each wraps.
  • get_provider_evidenceHow each part of their score was established. Free — the basis for a claim should not sit behind it.
  • get_provider_ratingPRO — composite, band, trend and facet scores.
  • apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.
  • resolveTurn a domain, URL or GitHub org into the provider it belongs to.
  • find_cohortsEvery scored population of providers in the catalog.
All 92 tools →

Call it yourself

curl for this page
This provider 
curl "https://apis.io/api/v1/providers/apache-flink"
All providers 
curl "https://apis.io/api/v1/providers?limit=25"
Every operation they expose 
curl "https://apis.io/api/v1/providers/apache-flink/operations?limit=25"
How their score was established 
curl "https://apis.io/api/v1/providers/apache-flink/evidence"

Discovery needs no key. Ratings and market analysis are Pro.

Get an API key

Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.

GitHub Google LinkedIn

A second provider on the same verified email joins the account you already have.