Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-5863 Fixed AbstractFlowFileQueue logging 

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #3199.
This commit is contained in:
Koji Kawamura 2018-12-05 10:23:57 +09:00 committed by Pierre Villard
parent 6c1c9017e9
commit 8ebb4d1974
No known key found for this signature in database
GPG Key ID: BEE1599F0726E9CD
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/AbstractFlowFileQueue.java
View File

@ -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);
}