Update spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaD…

…ataSource.scala
delta-io · Feb 4, 2025 · 891167b · 891167b
1 parent dc59767
commit 891167b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaDataSource.scala b/spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaDataSource.scala
@@ -105,7 +105,8 @@ class DeltaDataSource
         .getOrElse(snapshot.schema)
     }
 
-    if (schema.nonEmpty && !DataType.equalsIgnoreCompatibleNullability(readSchema, schema.get)) {
+    if (schema.nonEmpty && schema.get.nonEmpty &&
+      !DataType.equalsIgnoreCompatibleNullability(readSchema, schema.get)) {
       throw DeltaErrors.specifySchemaAtReadTimeException
     }