You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2018/12/05 10:30:01 UTC
nifi git commit: NIFI-5863 Fixed AbstractFlowFileQueue logging
Repository: nifi
Updated Branches:
refs/heads/master 6c1c9017e -> 8ebb4d197
NIFI-5863 Fixed AbstractFlowFileQueue logging
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #3199.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/8ebb4d19
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/8ebb4d19
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/8ebb4d19
Branch: refs/heads/master
Commit: 8ebb4d19740a3ccb879c03b322b335d02b6b16dc
Parents: 6c1c901
Author: Koji Kawamura <ij...@apache.org>
Authored: Wed Dec 5 10:23:57 2018 +0900
Committer: Pierre Villard <pi...@gmail.com>
Committed: Wed Dec 5 11:29:50 2018 +0100
----------------------------------------------------------------------
.../org/apache/nifi/controller/queue/AbstractFlowFileQueue.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/8ebb4d19/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java
index 436b85d..b986791 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java
@@ -190,7 +190,6 @@ public abstract class AbstractFlowFileQueue implements FlowFileQueue {
@Override
public void run() {
int position = 0;
- int resultCount = 0;
final List<FlowFileSummary> summaries = new ArrayList<>();
// Create an ArrayList that contains all of the contents of the active queue.
@@ -216,7 +215,7 @@ public abstract class AbstractFlowFileQueue implements FlowFileQueue {
}
}
- logger.debug("{} Finished listing FlowFiles for active queue with a total of {} results", this, resultCount);
+ logger.debug("{} Finished listing FlowFiles for active queue with a total of {} results out of {} FlowFiles", this, summaries.size(), allFlowFiles.size());
listRequest.setFlowFileSummaries(summaries);
listRequest.setState(ListFlowFileState.COMPLETE);
}