diff --git a/paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java b/paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java index c5588b1d3769..e12ebf9852a9 100644 --- a/paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java +++ b/paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java @@ -200,6 +200,9 @@ private static Object toTypeObject(DataType dataType, int fieldId, int depth) { } public DataType getDataType() { + if (dataType != null) { + return dataType; + } String simpleType = type.toString(); String delimiter = "("; if (simpleType.contains("[")) {