Repository: nifi Updated Branches: refs/heads/master 986a2a484 -> 6c1c9017e
NIFI-5862 MockRecordParser Has Bad Logic for failAfterN This closes #3195. Signed-off-by: Koji Kawamura <ijokaruma...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/6c1c9017 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/6c1c9017 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/6c1c9017 Branch: refs/heads/master Commit: 6c1c9017e98b8467296bc90746dab73a60cb9c1b Parents: 986a2a4 Author: Peter Wicks <patric...@gmail.com> Authored: Mon Dec 3 10:44:01 2018 -0700 Committer: Koji Kawamura <ijokaruma...@apache.org> Committed: Wed Dec 5 10:09:31 2018 +0900 ---------------------------------------------------------------------- .../org/apache/nifi/serialization/record/MockRecordParser.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/6c1c9017/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java index 2f7c634..be4046c 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java @@ -79,7 +79,7 @@ public class MockRecordParser extends AbstractControllerService implements Recor @Override public Record nextRecord(final boolean coerceTypes, final boolean dropUnknown) throws IOException, MalformedRecordException { - if (failAfterN >= recordCount) { + if (failAfterN >= 0 && recordCount >= failAfterN) { throw new MalformedRecordException("Intentional Unit Test Exception because " + recordCount + " records have been read"); } recordCount++;
