NIFI-13657 Fixed Reducer for Processor Load Average in Node Status

This closes #9177 Signed-off-by: David Handermann <[email protected]>
apache · Aug 15, 2024 · e46c7db · e46c7db
1 parent 99f3717
commit e46c7db
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java b/...-shared/src/main/java/org/apache/nifi/controller/status/history/NodeStatusDescriptor.java
@@ -79,7 +79,7 @@ public Long reduce(final List<StatusSnapshot> values) {
                 @Override
                 public Long reduce(final List<StatusSnapshot> 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()