Skip to content

Commit 23a7f90

Browse files
authored
Fix the logging bug where we use the incorrect snapshot (delta-io#4355)
## Which Delta project/connector is this regarding? - [X] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ## Description Currently when we reconstruct the snapshot, we incorrectly record the old snapshot as the new one. This PR fixes it. ## How was this patch tested? Existing tests to catch regressions. ## Does this PR introduce _any_ user-facing changes? No
1 parent 39af931 commit 23a7f90

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark/src/main/scala/org/apache/spark/sql/delta/SnapshotManagement.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1060,7 +1060,7 @@ trait SnapshotManagement { self: DeltaLog =>
10601060
val newSnapshot = updateInternal(
10611061
isAsync = false,
10621062
catalogTableOpt)
1063-
sendEvent(newSnapshot = capturedSnapshot.snapshot)
1063+
sendEvent(newSnapshot = newSnapshot)
10641064
newSnapshot
10651065
}
10661066
}

0 commit comments

Comments
 (0)