From 50a34ffd638622da72c6667a4364e99055e3d505 Mon Sep 17 00:00:00 2001
From: Peter Wicks <patricker@gmail.com>
Date: Mon, 3 Dec 2018 10:44:01 -0700
Subject: [PATCH] NIFI-5862 MockRecordParser Has Bad Logic for failAfterN

---
 .../org/apache/nifi/serialization/record/MockRecordParser.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 2f7c63437cda..be4046cb54ba 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 void close() throws IOException {
 
             @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++;