Repository: nifi Updated Branches: refs/heads/master f239be289 -> 9ca0f95d0
nifi-1272 Fixing a bug in StandardProcessSession.get(int) which returns incorrect number of flowfiles Signed-off-by: Mark Payne <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/fa4c5314 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/fa4c5314 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/fa4c5314 Branch: refs/heads/master Commit: fa4c5314caed6960f9d2a9e9c115e7594972cee3 Parents: f239be2 Author: ianwww <[email protected]> Authored: Tue Dec 8 15:19:52 2015 -0500 Committer: Mark Payne <[email protected]> Committed: Fri Dec 18 11:50:39 2015 -0500 ---------------------------------------------------------------------- .../apache/nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/fa4c5314/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java index 22fee7f..d2ba55d 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java @@ -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;
