Github user ijokarumawak commented on the issue:
https://github.com/apache/nifi/pull/1877
@markap14 Thanks for pointing that out. I think I got mislead by the two
getSchema methods in SchemaRegistryService. I accidentally removed the 2nd form
during refactoring and that caused for the unnecessary InputStream sneaked into
RecordSetWriterFactory.
```
// This one had been used by readers
public final RecordSchema getSchema(final FlowFile flowFile, final
InputStream contentStream, final RecordSchema readSchema) throws
SchemaNotFoundException, IOException {
// This one had been used by writers
public RecordSchema getSchema(final FlowFile flowFile, final
RecordSchema readSchema) throws SchemaNotFoundException, IOException {
```
I pushed another commit to bring back the 2nd signature above, and change
FlowFile to Map<String, String>. Compiled and contrib-check passed locally.
Also tested different readers/writers with a live flow. Thanks again for your
time to review!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
