feat(charts/flink-job): add nodeselector to job spec (#326)

This is to utilize spotify/flink-on-k8s-operator#242
Nextdoor · Aug 9, 2024 · 7a1b40e · 7a1b40e
1 parent 4fa52fe
commit 7a1b40e
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 3 deletions.
diff --git a/charts/flink-job/Chart.yaml b/charts/flink-job/Chart.yaml
@@ -2,7 +2,7 @@ apiVersion: v2
 appVersion: "1.0"
 description: Flink job cluster on k8s
 name: flink-job
-version: 0.1.21
+version: 0.1.22
 maintainers:
   - name: Zedive
     email: albert@nextdoor.com
diff --git a/charts/flink-job/README.md b/charts/flink-job/README.md
@@ -2,7 +2,7 @@
 
 Flink job cluster on k8s
 
-![Version: 0.1.21](https://img.shields.io/badge/Version-0.1.21-informational?style=flat-square) ![AppVersion: 1.0](https://img.shields.io/badge/AppVersion-1.0-informational?style=flat-square)
+![Version: 0.1.22](https://img.shields.io/badge/Version-0.1.22-informational?style=flat-square) ![AppVersion: 1.0](https://img.shields.io/badge/AppVersion-1.0-informational?style=flat-square)
 
 This chart deploys a flink job cluster and runs a simple word counting flink app as an example.
 This chart includes some production ready set-ups such as
@@ -40,6 +40,7 @@ See metrics reporter in the flink properties for more details.
 | job.initContainers | object | `{"enabled":false}` | Init containers of the Job pod. It can be used to download a remote job jar to your job pod. It is only needed if you have no other way to download your job files into the Flink job cluster. |
 | job.jarFile | String | `"./examples/streaming/WordCount.jar"` | JAR file of the job |
 | job.mode | String | `"Detached"` | JobMode of the job submitter, either Detached or Blocking |
+| job.nodeSelector | string | `nil` | The node selector for the job |
 | job.parallelism | `int` | `1` | Parallelism of the job |
 | job.restartPolicy | String | `"FromSavepointOnFailure"` | Restart policy when the job fails, enum("Never", "FromSavepointOnFailure") |
 | job.savepointGeneration | `int` | `nil` | Update this field to jobStatus.savepointGeneration + 1 for a running job cluster to trigger a new savepoint to savepointsDir on demand. |

diff --git a/charts/flink-job/templates/flinkjobcluster.yaml b/charts/flink-job/templates/flinkjobcluster.yaml
@@ -390,6 +390,10 @@ spec:
     {{- if .Values.job.savepointGeneration }}
     savepointGeneration: {{ .Values.job.savepointGenaration }}
     {{- end }}
+    {{- with .Values.job.nodeSelector }}
+    nodeSelector:
+      {{- toYaml . | nindent 6 }} 
+    {{- end }}
     noLoggingToStdout: false
     parallelism: {{ .Values.job.parallelism }}
     restartPolicy: {{ .Values.job.restartPolicy }}
@@ -451,4 +455,4 @@ spec:
     {{ $property }}: {{ tpl $value $ | quote }}
     {{- end }}
     {{- end }}
-{{- end -}}
+{{- end -}}
diff --git a/charts/flink-job/values.yaml b/charts/flink-job/values.yaml
@@ -188,6 +188,8 @@ job:
     afterJobFails: KeepCluster
     afterJobCancelled: KeepCluster
     afterJobSucceeds: KeepCluster
+  # -- The node selector for the job
+  nodeSelector:
   # -- Init containers of the Job pod. It can be used to download a remote job jar to your job pod.
   # It is only needed if you have no other way to download your job files into the Flink job cluster.
   initContainers: