Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/3057#discussion_r223892405
--- Diff:
nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java
---
@@ -58,6 +58,10 @@ public void addSchemaField(final String fieldName, final
RecordFieldType type, b
fields.add(new RecordField(fieldName, type.getDataType(),
isNullable));
}
+ public void addSchemaField(final RecordField recordField) {
--- End diff --
This preserves the full data type of the field.
RecordFieldType.getDataType(), which is called from the other add() methods,
returns the "base" type, such as "ARRAY" instead of "ARRAY[INT]", for equality
purposes.
---
