Review with Ryan

malhotrashivam · Oct 25, 2024 · d2e1723 · d2e1723
1 parent b254ceb
commit d2e1723
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/extensions/iceberg/src/main/java/io/deephaven/iceberg/util/IcebergTableAdapter.java b/extensions/iceberg/src/main/java/io/deephaven/iceberg/util/IcebergTableAdapter.java
@@ -291,7 +291,9 @@ private SpecAndSchema getSpecAndSchema(@NotNull final IcebergReadInstructions re
         } else {
             // Use the schema from the snapshot
             snapshot = snapshotFromInstructions;
-            schema = schema(snapshot.schemaId()).get();
+            schema = schema(snapshot.schemaId()).orElseThrow(() -> new IllegalArgumentException(
+                    "Schema with id " + snapshot.schemaId() + " not found for table " + tableIdentifier + ", snapshot "
+                            + snapshot.snapshotId()));
             partitionSpec = table.spec();
             updatedInstructions = readInstructions.withSnapshot(snapshot);
         }