Add support for metrics for flink versions 1.17 and 1.18

trifork · Feb 14, 2024 · 742e0d9 · 742e0d9
1 parent 338a85e
commit 742e0d9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/charts/flink-job/templates/_helpers.tpl b/charts/flink-job/templates/_helpers.tpl
@@ -181,7 +181,7 @@ Add necessary metrics configuration
     {{- $configs = fromJson (include "flink-job._dictSet" (list $configs "metrics.reporter.prom.port" (toString .global.metrics.port))) -}}
     {{- if eq "v1_15" .global.version -}}
       {{- $configs = fromJson (include "flink-job._dictSet" (list $configs "metrics.reporter.prom.class" "org.apache.flink.metrics.prometheus.PrometheusReporter")) -}}
-    {{- else if eq "v1_16" .global.version -}}
+    {{- else if has .global.version (list "v1_16" "v1_17" "v1_18") -}}
       {{- $configs = fromJson (include "flink-job._dictSet" (list $configs "metrics.reporter.prom.factory.class" "org.apache.flink.metrics.prometheus.PrometheusReporterFactory")) -}}
     {{- end -}}
   {{- end -}}