This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new e46c7db1ec NIFI-13657 Fixed Reducer for Processor Load Average in Node
Status
e46c7db1ec is described below
commit e46c7db1ecb32ec0bd4910f3d15a7f407f60063d
Author: Bryan Bende <[email protected]>
AuthorDate: Wed Aug 14 15:14:40 2024 -0400
NIFI-13657 Fixed Reducer for Processor Load Average in Node Status
This closes #9177
Signed-off-by: David Handermann <[email protected]>
---
.../org/apache/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<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()
