Skip to content

Commit

Permalink
Added Flink K8s Operator related deployment files (#150)
Browse files Browse the repository at this point in the history
* Added handling of additional classpath modules

* fixes

* Added readme entry

* Added handling for flink-k8s-operator

* Added config field

* added sharedDirectory field

* Added missing conf field

* Added some flink-k8s-operator related yamls

* Added condition checking for clusterRoleBinding

* Added conditionals

* test

* test

* test

* test

* test

* experimenting with flink operator role

* fix

* Added resource policy to keep payload-pvc-nfs

* Testing pre-delete flink deployments script

* test

* improvement

* Added quota info

* fix

* Improvements

* improvements

* toggle for deleting flink deployments

* Moved sharedDirectoryMount to config

* removed unnecessary file

* Adapted to changed config file

* Added influx config for flink k8s operator

* Added job state storage + refactor

* Fixed grafana dashboard

* Added additional permissions to flink-service-account

* Added flinkVersion to config

* fix

* Added limitOfRunningScenarios config parameter

* potential fix

* fixes

* fix

* Added handling of customLimitOfRunningScenarioExceededMessage

* fix

* Added all optional parameters for flink k8s operator dm

* moved flink k8s operator config to enterprise section

* fix

* Moved pvc storage class value to config file

* fix

* fixes
  • Loading branch information
pielas authored Sep 6, 2024
1 parent 5e72e6d commit 9ab7cf4
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 3 deletions.
4 changes: 3 additions & 1 deletion src/templates/flink-k8s-operator/jar-shared-volume-pvc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,5 +15,7 @@ spec:
resources:
requests:
storage: {{ default "1Gi" .Values.enterprise.flinkK8sOperatorDeploymentManager.jobJarStorage.pvcSize }}
storageClassName: nfs
{{- with .Values.enterprise.flinkK8sOperatorDeploymentManager.jobJarStorage.pvcStorageClassName }}
storageClassName: {{ . }}
{{- end }}
{{- end }}
Original file line number Diff line number Diff line change
Expand Up @@ -15,5 +15,7 @@ spec:
resources:
requests:
storage: {{ default "1Gi" .Values.enterprise.flinkK8sOperatorDeploymentManager.jobStateStorage.pvcSize }}
storageClassName: nfs
{{- with .Values.enterprise.flinkK8sOperatorDeploymentManager.jobStateStorage.pvcStorageClassName }}
storageClassName: {{ . }}
{{- end }}
{{- end }}
4 changes: 3 additions & 1 deletion src/values.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -331,6 +331,8 @@ enterprise:
jobJarStorage:
pvcName: job-jars-pvc
mountPoint: /mnt/jobjars
# pvcStorageClassName: default
jobStateStorage:
pvcName: job-states-pvc
mountPoint: /mnt/jobstates
mountPoint: /mnt/jobstates
# pvcStorageClassName: default

0 comments on commit 9ab7cf4

Please sign in to comment.