[FLINK-26784] FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: kubernetes-operator-1.0.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• Assignee: WenJun Min
• Reporter: WenJun Min
• Created: 21/Mar/22 14:38
• Updated: 19/May/22 14:37
• Resolved: 19/May/22 08:33

Description

https://cwiki.apache.org/confluence/display/FLINK/FLIP-215%3A+Introduce+FlinkSessionJob+CRD+in+the+kubernetes+operator

Issue Links

• links to: GitHub Pull Request #215

Sub-Tasks

• Add FlinkSessionJob CRD: Closed
• Implement FlinkSessionJobController and Reconciler: Closed
• Implement session job observer: Closed
• Handle Session job spec change: Closed
• Extend the Reconciler and Observer interface: Closed
• Add e2e tests for FlinkSessionJob type: Closed
• Support user jar from different type of filesystems: Closed
• Enrich validator for FlinkSessionJob: Closed
• Clean up the jar file after submitting the job: Closed
• Add document of session job operations: Closed
• Prevent session cluster to be deleted when there are running jobs: Closed
• Support restartNonce semantics in session job: Closed
• Generate waring events when deleting the session cluster: Closed
• Use informer in webhook to avoid query apiserver at each update: Closed