Fix for metadata tables

apache · Feb 27, 2023 · b2692fe · b2692fe
1 parent 51a29b3
commit b2692fe
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java
@@ -22,6 +22,7 @@
 import java.util.List;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
+import org.apache.iceberg.BaseMetadataTable;
 import org.apache.iceberg.BaseTable;
 import org.apache.iceberg.BatchScan;
 import org.apache.iceberg.FileScanTask;
@@ -374,7 +375,11 @@ private Scan buildBatchScan() {
         readConf.branch(),
         branch);
 
-    Snapshot branchSnapshot = SnapshotUtil.latestSnapshot(table, branch);
+    Snapshot branchSnapshot = null;
+    if (!(table instanceof BaseMetadataTable)) {
+      branchSnapshot = SnapshotUtil.latestSnapshot(table, branch);
+    }
+
     Long snapshotId = branchSnapshot != null ? branchSnapshot.snapshotId() : null;
     Long asOfTimestamp = readConf.asOfTimestamp();
     String tag = readConf.tag();