diff --git a/xtable-core/src/main/java/org/apache/xtable/delta/DeltaSchemaExtractor.java b/xtable-core/src/main/java/org/apache/xtable/delta/DeltaSchemaExtractor.java index 5119f5f5c..d6e59a97c 100644 --- a/xtable-core/src/main/java/org/apache/xtable/delta/DeltaSchemaExtractor.java +++ b/xtable-core/src/main/java/org/apache/xtable/delta/DeltaSchemaExtractor.java @@ -101,7 +101,8 @@ private InternalSchema toInternalSchema( type = InternalType.DOUBLE; break; case "binary": - if (originalMetadata.contains(InternalSchema.XTABLE_LOGICAL_TYPE) + if (originalMetadata != null + && originalMetadata.contains(InternalSchema.XTABLE_LOGICAL_TYPE) && "uuid".equals(originalMetadata.getString(InternalSchema.XTABLE_LOGICAL_TYPE))) { type = InternalType.UUID; } else {