FlinkKubernetesSensor
Apache FlinkChecks flinkDeployment object in kubernetes cluster:
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.
Parameters
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
Documentation
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