apache-airflow-providers-apache-flink

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 on this page — 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

apache-airflow-providers-apache-flink on PyPI

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

Evidence: apache_airflow_providers_apache_flink-1.8.5-py3-none-any.whl

Keywords: airflow-provider, apache.flink, airflow, integration

Tags

More Monitoring packages