Apache Flink

Checks flinkDeployment object in kubernetes cluster:

View on GitHub

Last Updated: Dec. 21, 2022

Access Instructions

Install the Apache Flink provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


application_nameRequiredflink Application resource name
namespacethe kubernetes namespace where the flinkDeployment reside in
kubernetes_conn_idThe kubernetes connection to Kubernetes cluster
attach_logdetermines whether logs for driver pod should be appended to the sensor log
api_groupkubernetes api group of flinkDeployment
api_versionkubernetes api version of flinkDeployment
pluralkubernetes api custom object plural


Checks flinkDeployment object in kubernetes cluster:

See also

For more detail about Flink Deployment Object have a look at the reference: https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment

Was this page helpful?