NIFI-3995: This closes apache#1873. No longer use the 14th byte in th…

…e header for hwx content-encoded schema reference Signed-off-by: joewitt <joewitt@apache.org>
aperepel · May 31, 2017 · a0b2311 · a0b2311
1 parent 7bcccb1
commit a0b2311
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/...rc/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceStrategy.java b/...rc/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceStrategy.java
@@ -46,7 +46,7 @@ public HortonworksEncodedSchemaReferenceStrategy(final SchemaRegistry schemaRegi
 
     @Override
     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 {
             StreamUtils.fillBuffer(contentStream, buffer);
         } catch (final IOException ioe) {

diff --git a/.../src/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceWriter.java b/.../src/main/java/org/apache/nifi/schema/access/HortonworksEncodedSchemaReferenceWriter.java
@@ -47,7 +47,6 @@ public void writeHeader(final RecordSchema schema, final OutputStream out) throw
         bb.put((byte) LATEST_PROTOCOL_VERSION);
         bb.putLong(id);
         bb.putInt(version);
-        bb.put((byte) 0); // We always use generic records
 
         out.write(bb.array());
     }