Fixed a bug that wrong sidecar size passed into reader

trinodb · Feb 28, 2025 · 8bf4889 · 8bf4889
1 parent 1df7d66
commit 8bf4889
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/TableSnapshot.java b/...rino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/TableSnapshot.java
@@ -347,7 +347,7 @@ private Stream<DeltaLakeTransactionLogEntry> getV2CheckpointTransactionLogEntrie
                     CheckpointEntryIterator iterator = new CheckpointEntryIterator(
                             fileSystem.newInputFile(sidecar),
                             session,
-                            fileSize,
+                            entry.getSidecar().sizeInBytes(),
                             checkpointSchemaManager,
                             typeManager,
                             dataEntryTypes,