Parcourir la source

Add ability to specify generic configuration parameters

vkropotko il y a 5 ans
Parent
commit
ca3d082885
2 fichiers modifiés avec 2 ajouts et 0 suppressions
  1. 1 0
      templates/_helpers.tpl
  2. 1 0
      values.yaml

+ 1 - 0
templates/_helpers.tpl

@@ -108,6 +108,7 @@ provide jobmanager.rpc.address to Taskmanagers
     taskmanager.rpc.port: {{ .Values.taskmanager.ports.rpc }}
     jobmanager.heap.size: {{ .Values.jobmanager.heapSize }}
     taskmanager.heap.size: {{ .Values.taskmanager.heapSize }}
+    {{- .Values.flink.params | nindent 4 }}
     {{- if .Values.flink.monitoring.enabled }}
     metrics.reporters: prom
     metrics.reporter.prom.class: org.apache.flink.metrics.prometheus.PrometheusReporter

+ 1 - 0
values.yaml

@@ -29,6 +29,7 @@ flink:
     rocksdb:
       enabled: false
   workDir: /opt/flink
+  params: ""
   state:
     # backend for state. Available options: filesystem, rocksdb, memory; empty - for default(memory)
     backend: