[FLINK-31857] Support pluginable observers mechanism

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: kubernetes-operator-1.5.0
• Component/s: Kubernetes Operator
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Unassigned
• Reporter: Daren Wong
• Created: 19/Apr/23 15:00
• Updated: 11/Sep/23 22:35

Description

Currently, Kubernetes Operator uses AbstractFlinkResourceObserver to observe Flink Job state, cluster state, JM/TM state, etc and update Custom Resource: FlinkDeployment, FlinkSessionJob with the gathered info.

This Jira is to introduce a Flink plugin to allow user to implement custom observer logic after the default observer logic is run.

Issue Links

• links to: GitHub Pull Request #570