Class ClusterHealthObserver
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
-
public class ClusterHealthObserver extends java.lang.Object
An observer to observe the cluster health.
-
-
Constructor Summary
Constructors Constructor Description ClusterHealthObserver(FlinkService flinkService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observe(FlinkDeployment flinkApp, org.apache.flink.configuration.Configuration deployedConfig)
Observe the health of the flink cluster.
-
-
-
Constructor Detail
-
ClusterHealthObserver
public ClusterHealthObserver(FlinkService flinkService)
-
-
Method Detail
-
observe
public void observe(FlinkDeployment flinkApp, org.apache.flink.configuration.Configuration deployedConfig)
Observe the health of the flink cluster.
-
-