You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2017/06/13 16:35:39 UTC
nifi git commit: NIFI-1921: Fixed bug in how average lineage duration
was calculated for cluster stat
Repository: nifi
Updated Branches:
refs/heads/master 2b47ade0c -> c0ad5bcc7
NIFI-1921: Fixed bug in how average lineage duration was calculated for cluster stat
Signed-off-by: Matt Burgess <ma...@apache.org>
This closes #1912
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/c0ad5bcc
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/c0ad5bcc
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/c0ad5bcc
Branch: refs/heads/master
Commit: c0ad5bcc7bf487c4097c7e6db77bf4e3254c0618
Parents: 2b47ade
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Jun 12 16:23:39 2017 -0400
Committer: Matt Burgess <ma...@apache.org>
Committed: Tue Jun 13 12:29:03 2017 -0400
----------------------------------------------------------------------
.../controller/status/history/ProcessorStatusDescriptor.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/c0ad5bcc/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ProcessorStatusDescriptor.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ProcessorStatusDescriptor.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ProcessorStatusDescriptor.java
index 59a4b1b..f939273 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ProcessorStatusDescriptor.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ProcessorStatusDescriptor.java
@@ -115,12 +115,13 @@ public enum ProcessorStatusDescriptor {
for (final StatusSnapshot snapshot : values) {
final long removed = snapshot.getStatusMetrics().get(FLOWFILES_REMOVED.getDescriptor()).longValue();
- count += removed;
+ final long outputCount = snapshot.getStatusMetrics().get(OUTPUT_COUNT.getDescriptor()).longValue();
+ final long processed = removed + outputCount;
- count += snapshot.getStatusMetrics().get(OUTPUT_COUNT.getDescriptor()).longValue();
+ count += processed;
final long avgMillis = snapshot.getStatusMetrics().get(AVERAGE_LINEAGE_DURATION.getDescriptor()).longValue();
- final long totalMillis = avgMillis * removed;
+ final long totalMillis = avgMillis * processed;
millis += totalMillis;
}