Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-03-06 17:39:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-8437 RecordReader 'Infer Schema' for large records may throw BufferedInputStream error

Browse Source 
This closes #5011.

Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
Denes Arvay 2021-04-20 10:00:47 +02:00 committed by Mark Payne
parent 92bdc23adb
commit 9f45b48866
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/JsonPathReader.java
View File

@ -46,7 +46,6 @@ import org.apache.nifi.serialization.SchemaRegistryService;
import org.apache.nifi.serialization.record.RecordSchema; import org.apache.nifi.serialization.record.RecordSchema;
import org.codehaus.jackson.JsonNode; import org.codehaus.jackson.JsonNode;
import java.io.BufferedInputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.util.ArrayList; import java.util.ArrayList;
@ -164,9 +163,8 @@ public class JsonPathReader extends SchemaRegistryService implements RecordReade
@Override @Override
public RecordReader createRecordReader(final Map<String, String> variables, final InputStream in, final long inputLength, final ComponentLog logger) public RecordReader createRecordReader(final Map<String, String> variables, final InputStream in, final long inputLength, final ComponentLog logger)
throws IOException, MalformedRecordException, SchemaNotFoundException { throws IOException, MalformedRecordException, SchemaNotFoundException {
final InputStream bufferedIn = new BufferedInputStream(in); final RecordSchema schema = getSchema(variables, in, null);
final RecordSchema schema = getSchema(variables, bufferedIn, null); return new JsonPathRowRecordReader(jsonPaths, schema, in, logger, dateFormat, timeFormat, timestampFormat);
return new JsonPathRowRecordReader(jsonPaths, schema, bufferedIn, logger, dateFormat, timeFormat, timestampFormat);
} }
} }