Merge pull request #200 from trifork/add-metrics-support-for-flink-1.…

…17-1.18 Add support for metrics for flink versions 1.17 and 1.18
trifork · Feb 15, 2024 · f73debd · f73debd
2 parents 338a85e + 742e0d9
commit f73debd
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 -}}