diff --git a/pkg/ccl/backupccl/backup_test.go b/pkg/ccl/backupccl/backup_test.go index f427ca11e25b..196f4b5d40f4 100644 --- a/pkg/ccl/backupccl/backup_test.go +++ b/pkg/ccl/backupccl/backup_test.go @@ -1811,7 +1811,7 @@ func TestBackupRestoreResume(t *testing.T) { }, }, // Required because restore checkpointing is version gated. - clusterversion.ByKey(clusterversion.V23_1Start), + clusterversion.ByKey(clusterversion.V23_1), ) // If the restore properly took the (incorrect) low-water mark into account, // the first half of the table will be missing. diff --git a/pkg/ccl/backupccl/restore_job.go b/pkg/ccl/backupccl/restore_job.go index ad9e5593ad3d..96867aeafdf0 100644 --- a/pkg/ccl/backupccl/restore_job.go +++ b/pkg/ccl/backupccl/restore_job.go @@ -287,7 +287,7 @@ func restore( return emptyRowCount, err } - on231 := clusterversion.ByKey(clusterversion.V23_1Start).LessEq(job.Payload().CreationClusterVersion) + on231 := clusterversion.ByKey(clusterversion.V23_1).LessEq(job.Payload().CreationClusterVersion) progressTracker, err := makeProgressTracker( dataToRestore.getSpans(), job.Progress().Details.(*jobspb.Progress_Restore).Restore.Checkpoint,