Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31857

Support pluginable observers mechanism

    XMLWordPrintableJSON

Details

    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.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #570

          Activity

            People

              Unassigned Unassigned
              darenwkt Daren Wong
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: