diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java index 24aa391e5b2..afa43246a96 100644 --- a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java +++ b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/snapshot/SnapshotManager.java @@ -525,6 +525,8 @@ private SnapshotImpl createSnapshot(LogSegment initSegment, Engine engine) { .orElse("."); logger.info("{}: Loading version {} {}", tablePath, initSegment.version, startingFromStr); + long startTimeMillis = System.currentTimeMillis(); + LogReplay logReplay = new LogReplay( logPath, @@ -534,8 +536,6 @@ private SnapshotImpl createSnapshot(LogSegment initSegment, Engine engine) { initSegment, Optional.ofNullable(latestSnapshotHint.get())); - long startTimeMillis = System.currentTimeMillis(); - assertLogFilesBelongToTable(logPath, initSegment.allLogFilesUnsorted()); final SnapshotImpl snapshot =