---
id: apache-airflow-providers-apache-flink
version: "1.8.5"
license: Apache-2.0
license_treatment: permissive
maintenance: active
---

# apache-airflow-providers-apache-flink — Provider package apache-airflow-providers-apache-flink for Apache Airflow

License: permissive · Maintenance: active · Downloads: 344.5K/mo

## What it is and what it does

This is an Apache Airflow provider package that bridges Airflow's workflow orchestration with Apache Flink stream and batch processing. It supplies operators, hooks, and sensors that allow you to define Flink jobs as native Airflow tasks, schedule them alongside other workloads, and monitor their execution within Airflow's UI.

The package depends on core Airflow (>=2.11.0), cryptography for secure credential handling, and optionally the Kubernetes provider for cloud-native Flink deployments. It supports Python 3.10 through 3.14 and is actively maintained by the Apache Airflow project, with no known security vulnerabilities.

Use it for:

- Schedule and monitor Apache Flink SQL or streaming jobs as part of a larger Airflow data pipeline.
- Integrate Flink batch processing into multi-step ETL workflows orchestrated by Airflow.
- Deploy Flink jobs on Kubernetes clusters via Airflow, using the optional Kubernetes provider.
- Manage Flink job dependencies and error handling within Airflow's DAG framework.

## Worth the install?

AI-flagged interpretation of the facts above — verify before relying.

Provides Apache Airflow integration for Apache Flink, enabling you to orchestrate and monitor Flink jobs as tasks within Airflow workflows.

Yes. This is a production-stable, actively maintained provider from the Apache Airflow project with no security vulnerabilities, low install friction, and permissive licensing. Install it if you run Airflow and need to orchestrate Flink workloads; it is the standard integration for that use case.

## Install

pip install apache-airflow-providers-apache-flink
uv add apache-airflow-providers-apache-flink
poetry add apache-airflow-providers-apache-flink

## Installing apache-airflow-providers-apache-flink

Before you install: Low friction installation with a pure-Python wheel. Actively maintained with recent releases; requires Airflow >=2.11.0 and modern Python (3.10+).

License in practice: Apache-2.0 permissive license allows commercial use, modification, and distribution with minimal restrictions.

Quickstart:

pip install apache-airflow-providers-apache-flink

from airflow.providers.apache.flink.operators import FlinkSqlOperator
# Use FlinkSqlOperator in your DAG to submit Flink SQL jobs

Requires an existing Airflow installation (>=2.11.0) and Python 3.10 or later.

Verify before relying:

- Specific operators and hooks available in this version beyond what the description excerpt states.
- Whether Kubernetes integration (via apache-airflow-providers-cncf-kubernetes) is required or optional for typical Flink deployments.

## Package facts

- License: Apache-2.0 (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: active
- Downloads: 344.5K/month (top 15,000 on PyPI)
- Known vulnerabilities: none known

## Tags

airflow flink integration, orchestrate flink jobs, airflow provider flink, flink task operator airflow, flink workflow scheduling, airflow-provider, flink-integration, workflow-orchestration

[View on SkillFed](https://skillfed.io/packages/apache-airflow-providers-apache-flink) · [View on PyPI](https://pypi.org/project/apache-airflow-providers-apache-flink/)