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

nifi-1272 Fixing a bug in StandardProcessSession.get(int) which returns incorrect number of flowfiles 

Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
ianwww 2015-12-08 15:19:52 -05:00 committed by Mark Payne
parent f239be289e
commit fa4c5314ca
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
View File

@ -1210,7 +1210,7 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
@Override
public FlowFileFilterResult filter(final FlowFile flowFile) {
if (++polled <= maxResults) {
if (++polled < maxResults) {
return FlowFileFilterResult.ACCEPT_AND_CONTINUE;
} else {
return FlowFileFilterResult.ACCEPT_AND_TERMINATE;