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

NIFI-226: when pre-fetching FlowFiles from queue, if a FlowFile is penalized, it is lost

This commit is contained in:
Mark Payne 2015-01-05 15:36:40 -05:00
parent 68b7ad78cc
commit a2ecfe3355
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1011,6 +1011,9 @@ public final class StandardFlowFileQueue implements FlowFileQueue {
if (record == null || record.isPenalized()) { if (record == null || record.isPenalized()) {
// not enough unpenalized records to pull. Put all records back and return // not enough unpenalized records to pull. Put all records back and return
activeQueue.addAll(buffer); activeQueue.addAll(buffer);
if ( record != null ) {
activeQueue.add(record);
}
return; return;
} else { } else {
buffer.add(record); buffer.add(record);