From 2ce7df9ddbdea7ad1f5e66a6847fb4e07d6824f7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Bigorajski?= Date: Tue, 7 Jan 2025 16:28:42 +0100 Subject: [PATCH 1/2] Handle node selector in flink operator --- src/templates/configmap.yaml | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/templates/configmap.yaml b/src/templates/configmap.yaml index ae5bd6c..89e1935 100644 --- a/src/templates/configmap.yaml +++ b/src/templates/configmap.yaml @@ -66,6 +66,10 @@ data: {{- if .Values.enterprise.flinkK8sOperatorDeploymentManager.taskManagerReplicas }} taskManagerReplicas: {{ .Values.enterprise.flinkK8sOperatorDeploymentManager.taskManagerReplicas | quote }} {{- end }} + {{- with .Values.nodeSelector }} + nodeSelector: + {{- toYaml . | nindent 2 }} + {{- end }} } {{- else if eq .Values.nussknacker.mode "ververica" }} deploymentConfig: { From ab15317764a21575b494dc8a16fbfb5528e91e5f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Bigorajski?= Date: Tue, 7 Jan 2025 16:42:32 +0100 Subject: [PATCH 2/2] fixes --- src/templates/configmap.yaml | 4 ++-- src/values.yaml | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/templates/configmap.yaml b/src/templates/configmap.yaml index 89e1935..0649805 100644 --- a/src/templates/configmap.yaml +++ b/src/templates/configmap.yaml @@ -66,9 +66,9 @@ data: {{- if .Values.enterprise.flinkK8sOperatorDeploymentManager.taskManagerReplicas }} taskManagerReplicas: {{ .Values.enterprise.flinkK8sOperatorDeploymentManager.taskManagerReplicas | quote }} {{- end }} - {{- with .Values.nodeSelector }} + {{- if .Values.enterprise.flinkK8sOperatorDeploymentManager.nodeSelector }} nodeSelector: - {{- toYaml . | nindent 2 }} + {{ .Values.enterprise.flinkK8sOperatorDeploymentManager.nodeSelector | toYaml | indent 2 }} {{- end }} } {{- else if eq .Values.nussknacker.mode "ververica" }} diff --git a/src/values.yaml b/src/values.yaml index 84b6c22..795bdaa 100644 --- a/src/values.yaml +++ b/src/values.yaml @@ -350,3 +350,4 @@ enterprise: pvcName: job-states-pvc mountPoint: /mnt/jobstates # pvcStorageClassName: default + nodeSelector: { }