Initialize flow metrics if pipeline metric.collect params is enabled. (…

…#16881)
elastic · Jan 9, 2025 · 47d04d0 · 47d04d0
1 parent 4554749
commit 47d04d0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/logstash-core/src/main/java/org/logstash/execution/AbstractPipelineExt.java b/logstash-core/src/main/java/org/logstash/execution/AbstractPipelineExt.java
@@ -558,6 +558,7 @@ public final IRubyObject collectStats(final ThreadContext context) throws IOExce
     @JRubyMethod(name = "initialize_flow_metrics")
     public final IRubyObject initializeFlowMetrics(final ThreadContext context) {
         if (metric.collector(context).isNil()) { return context.nil; }
+        if (!getSetting(context, "metric.collect").isTrue()) { return context.nil; }
 
         final UptimeMetric uptimeMetric = initOrGetUptimeMetric(context, buildNamespace(), UPTIME_IN_MILLIS_KEY);
         final Metric<Number> uptimeInPreciseMillis = uptimeMetric.withUnitsPrecise(MILLISECONDS);