From 9f45b48866eb87737ff370dd55b37de768f4d754 Mon Sep 17 00:00:00 2001 From: Denes Arvay Date: Tue, 20 Apr 2021 10:00:47 +0200 Subject: [PATCH] NIFI-8437 RecordReader 'Infer Schema' for large records may throw BufferedInputStream error This closes #5011. Signed-off-by: Mark Payne --- .../src/main/java/org/apache/nifi/json/JsonPathReader.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonPathReader.java b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonPathReader.java index f16106d61e..0662e1dfe0 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonPathReader.java +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonPathReader.java @@ -46,7 +46,6 @@ import org.apache.nifi.serialization.SchemaRegistryService; import org.apache.nifi.serialization.record.RecordSchema; import org.codehaus.jackson.JsonNode; -import java.io.BufferedInputStream; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; @@ -164,9 +163,8 @@ public class JsonPathReader extends SchemaRegistryService implements RecordReade @Override public RecordReader createRecordReader(final Map variables, final InputStream in, final long inputLength, final ComponentLog logger) throws IOException, MalformedRecordException, SchemaNotFoundException { - final InputStream bufferedIn = new BufferedInputStream(in); - final RecordSchema schema = getSchema(variables, bufferedIn, null); - return new JsonPathRowRecordReader(jsonPaths, schema, bufferedIn, logger, dateFormat, timeFormat, timestampFormat); + final RecordSchema schema = getSchema(variables, in, null); + return new JsonPathRowRecordReader(jsonPaths, schema, in, logger, dateFormat, timeFormat, timestampFormat); } }