Github user bbende commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2523#discussion_r174895925
--- Diff:
nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/src/main/java/org/apache/nifi/schema/access/HortonworksAttributeSchemaReferenceWriter.java
---
@@ -40,8 +40,8 @@ public void writeHeader(RecordSchema schema, OutputStream
out) throws IOExceptio
final Map<String, String> attributes = new HashMap<>(4);
final SchemaIdentifier id = schema.getIdentifier();
- final long schemaId = id.getIdentifier().getAsLong();
- final int schemaVersion = id.getVersion().getAsInt();
+ final Long schemaId = id.getIdentifier().getAsLong();
+ final Integer schemaVersion = id.getVersion().getAsInt();
attributes.put(HortonworksAttributeSchemaReferenceStrategy.SCHEMA_ID_ATTRIBUTE,
String.valueOf(schemaId));
attributes.put(HortonworksAttributeSchemaReferenceStrategy.SCHEMA_VERSION_ATTRIBUTE,
String.valueOf(schemaVersion));
--- End diff --
We can do that... one unfortunate thing though is that we will only have
the branch name if we also did the lookup with the branch name. If you do the
lookup by id+version then nothing I can see on the client API tells you the
branch name (i.e. SchemaVersionInfo does not have getBranchName())
---
