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.
---