From e46c7db1ecb32ec0bd4910f3d15a7f407f60063d Mon Sep 17 00:00:00 2001 From: Bryan Bende Date: Wed, 14 Aug 2024 15:14:40 -0400 Subject: [PATCH] NIFI-13657 Fixed Reducer for Processor Load Average in Node Status This closes #9177 Signed-off-by: David Handermann --- .../nifi/controller/status/history/NodeStatusDescriptor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java b/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java index b6bd14be88..dd43870e17 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java +++ b/nifi-framework-bundle/nifi-framework/nifi-framework-status-history-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java @@ -79,7 +79,7 @@ public enum NodeStatusDescriptor { @Override public Long reduce(final List values) { return (long) values.stream() - .map(snapshot -> snapshot.getStatusMetric(HEAP_UTILIZATION.getDescriptor())) + .map(snapshot -> snapshot.getStatusMetric(PROCESSOR_LOAD_AVERAGE.getDescriptor())) .filter(Objects::nonNull) .mapToLong(value -> value) .average()