Apache Flink

apache-airflow-providers-apache-flink

Apache Flink

Works with Airflow 2.11+

Install:

pip install apache-airflow-providers-apache-flink==1.8.3

Version:

2.11+

>=3.10

Show all Hide

apache-airflow>=2.11.0 apache-airflow-providers-common-compat>=1.10.1 cryptography>=44.0.3 apache-airflow-providers-cncf-kubernetes>=5.1.0

No connections

Modules

Creates flinkDeployment object in kubernetes cluster.

airflow.providers.apache.flink.operators.flink_kubernetes.FlinkKubernetesOperator

Checks flinkDeployment object in kubernetes cluster.

airflow.providers.apache.flink.sensors.flink_kubernetes.FlinkKubernetesSensor