Bulk Operation

FLINK-25963 Align the helm chart version with the flink operator

FLINK-25963 Add sanity check for state.savepoints.dir when using savepoint upgrade mode

FLINK-25963 Output more status info for JobObserver

FLINK-25963 Move jobs to suspended state before upgrading

FLINK-25963 The batch job not work well with Operator

FLINK-25963 Link operator doc site to Flink Website

FLINK-25963 Individual upgradeMode change does not trigger a reconciliation

FLINK-25963 Rethink the default reschedule reconcile loop

FLINK-25963 E2E tests should cover different watchNamespace scenarios

FLINK-25963 Remove .sec from OperatorConfigOptions and use Duration type config instead

FLINK-25963 Introduce Ingress URL templating

FLINK-25963 Set ClusterIP service type when watching specific namespaces

FLINK-25963 Specify EventSource when watching multiple namespaces

FLINK-25963 Improve the observe logic in SessionObserver

FLINK-25963 Add startTime in JobStatus

FLINK-25963 Consider changing flinkVersion to enum type or removing it completely

FLINK-25963 Mark CRD classes experimental

FLINK-25963 Check if JM can serve rest api calls every time before reconcile

FLINK-25963 Avoid state loss when switching to last-state upgrade mode

FLINK-25963 Allow definining Operator configuration in Helm chart Values

FLINK-25963 Re-schedule reconcile more often until job is in ready state

FLINK-25963 Savepoint trigger/tracking improvements

FLINK-25963 Clean termination of FlinkDeployment

FLINK-25963 Try to use @EnableKubernetesMockClient(crud = true) in controller test

FLINK-25963 Extract Observer Interface

FLINK-25963 Ability to restart deployment w/o spec change

FLINK-25963 Trigger the updateControl when the FlinkDeployment have changed

FLINK-25963 Reconsider setting generationAwareEventProcessing = true

FLINK-25963 Webhook should only validate on /validate endpoint end log errors for others

FLINK-25963 Last state upgrade mode should allow reconciliation regardless of job and deployment status

FLINK-25963 Introduce flink-kubernetes-shaded to avoid overlapping classes

FLINK-25963 Observer should support JobManager deployment crashed or deleted externally

FLINK-25963 Introduce Savepoint object in JobStatus

FLINK-25963 Deleting the operator while jobs are running causes the jobs to fail

FLINK-25963 Improve operator logging

FLINK-25963 Clean up webhook jar and dependency management

FLINK-25963 SharedIndexInformer should respect watched namespaces

FLINK-25963 Cleanly separate validator, observer and reconciler modules

FLINK-25963 Add validation check of num of JM replica

FLINK-25963 Make some option of operator configurable

FLINK-25963 Extract Reconciler interface

FLINK-25963 Make Flink cluster communication asynchronous

FLINK-25963 Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

FLINK-25963 Revisit the create of RestClusterClient

FLINK-25963 Introduce the webhook config to free the environment options

FLINK-25963 Avoid load flink conf each reconcile loop

FLINK-25963 Deletion should remove HA related configmaps also

FLINK-25963 Move the Operator Env to the common Utils

FLINK-25963 Control Logging Behavior in Flink Deployments

FLINK-25963 Remove need for flink-operator clusterrole

FLINK-25963 Revisit serviceAccount and taskSlots direct fields in CRD

FLINK-25963 Reconciliation should try to start job when not already started or move to permanent error

FLINK-25963 Support watching specific namespace for FlinkDeployments

FLINK-25963 Document metrics configuration for Prometheus

FLINK-25963 Track and cap retries in ReconciliationStatus

FLINK-25963 Make 'replicas' work in JobManager Spec

FLINK-25963 Publish Kubernetes operator to container registry

FLINK-25963 Commit generated CRD into Git repo

FLINK-25963 Support kubernetes-operator metrics using the Flink metric system

FLINK-25963 Support manual savepoint triggering in the operator

FLINK-25963 Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

FLINK-25963 Refactor FlinkUtils#getEffectiveConfig into smaller pieces

FLINK-25963 Containers Should Not Run As Root

FLINK-25963 Integrate flink-kubernetes-operator repo with CI/CD

FLINK-25963 Support last-state upgrade mode

FLINK-25963 Improve JobStatus tracking and handle different job states

FLINK-25963 Create controller test for stateful/stateless upgrade flow

FLINK-25963 Create webhook REST api test

FLINK-25963 Implement shared validation logic for FlinkDeployment objects

FLINK-25963 Separate job and deployment errors in FlinkDeployment status

FLINK-25963 Initial Kubernetes Operator Prototype contribution