Repository: nifi Updated Branches: refs/heads/master 6c1c9017e -> 8ebb4d197
NIFI-5863 Fixed AbstractFlowFileQueue logging Signed-off-by: Pierre Villard <[email protected]> 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 <[email protected]> Authored: Wed Dec 5 10:23:57 2018 +0900 Committer: Pierre Villard <[email protected]> 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); }
