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

NIFI-3995: This closes #1873. No longer use the 14th byte in the header for hwx content-encoded schema reference

Browse Source 
Signed-off-by: joewitt <joewitt@apache.org>
This commit is contained in:
Mark Payne 2017-05-31 12:20:02 -04:00 committed by joewitt
parent 7bcccb10f4
commit a0b2311ff6
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/src/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceStrategy.java
View File

@ -46,7 +46,7 @@ public class HortonworksEncodedSchemaReferenceStrategy implements SchemaAccessSt
@Override @Override
public RecordSchema getSchema(final FlowFile flowFile, final InputStream contentStream) throws SchemaNotFoundException, IOException { public RecordSchema getSchema(final FlowFile flowFile, final InputStream contentStream) throws SchemaNotFoundException, IOException {
final byte[] buffer = new byte[14]; final byte[] buffer = new byte[13];
try { try {
StreamUtils.fillBuffer(contentStream, buffer); StreamUtils.fillBuffer(contentStream, buffer);
} catch (final IOException ioe) { } catch (final IOException ioe) {

1
nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/src/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceWriter.java
View File

@ -47,7 +47,6 @@ public class HortonworksEncodedSchemaReferenceWriter implements SchemaAccessWrit
bb.put((byte) LATEST_PROTOCOL_VERSION); bb.put((byte) LATEST_PROTOCOL_VERSION);
bb.putLong(id); bb.putLong(id);
bb.putInt(version); bb.putInt(version);
bb.put((byte) 0); // We always use generic records
out.write(bb.array()); out.write(bb.array());
} }