diff --git a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java index ede34753100e..8e0c2e2e897d 100644 --- a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java +++ b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java @@ -1957,8 +1957,6 @@ public static DataType getDataTypeFromSQLTypeValue(final int sqlType) { return RecordFieldType.BOOLEAN.getDataType(); case Types.TINYINT: return RecordFieldType.BYTE.getDataType(); - case Types.CHAR: - return RecordFieldType.CHAR.getDataType(); case Types.DATE: return RecordFieldType.DATE.getDataType(); case Types.DOUBLE: @@ -1971,6 +1969,7 @@ public static DataType getDataTypeFromSQLTypeValue(final int sqlType) { return RecordFieldType.INT.getDataType(); case Types.SMALLINT: return RecordFieldType.SHORT.getDataType(); + case Types.CHAR: case Types.VARCHAR: case Types.LONGNVARCHAR: case Types.LONGVARCHAR: