Skip to content

Commit 639482c

Browse files
authored
Make --pitrRestoredTs optional in restore CR (#6135)
1 parent 40b4c6a commit 639482c

File tree

4 files changed

+6
-2
lines changed

4 files changed

+6
-2
lines changed

docs/api-references/docs.md

+2
Original file line numberDiff line numberDiff line change
@@ -1399,6 +1399,7 @@ string
13991399
</em>
14001400
</td>
14011401
<td>
1402+
<em>(Optional)</em>
14021403
<p>PitrRestoredTs is the pitr restored ts.</p>
14031404
</td>
14041405
</tr>
@@ -15466,6 +15467,7 @@ string
1546615467
</em>
1546715468
</td>
1546815469
<td>
15470+
<em>(Optional)</em>
1546915471
<p>PitrRestoredTs is the pitr restored ts.</p>
1547015472
</td>
1547115473
</tr>

pkg/apis/pingcap/v1alpha1/types.go

+1
Original file line numberDiff line numberDiff line change
@@ -2735,6 +2735,7 @@ type RestoreSpec struct {
27352735
// +kubebuilder:default=snapshot
27362736
Mode RestoreMode `json:"restoreMode,omitempty"`
27372737
// PitrRestoredTs is the pitr restored ts.
2738+
// +optional
27382739
PitrRestoredTs string `json:"pitrRestoredTs,omitempty"`
27392740
// LogRestoreStartTs is the start timestamp which log restore from.
27402741
// +optional

pkg/backup/restore/restore_manager.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -768,7 +768,9 @@ func (rm *restoreManager) makeRestoreJob(restore *v1alpha1.Restore) (*batchv1.Jo
768768
switch restore.Spec.Mode {
769769
case v1alpha1.RestoreModePiTR:
770770
args = append(args, fmt.Sprintf("--mode=%s", v1alpha1.RestoreModePiTR))
771-
args = append(args, fmt.Sprintf("--pitrRestoredTs=%s", restore.Spec.PitrRestoredTs))
771+
if restore.Spec.PitrRestoredTs != "" {
772+
args = append(args, fmt.Sprintf("--pitrRestoredTs=%s", restore.Spec.PitrRestoredTs))
773+
}
772774
case v1alpha1.RestoreModeVolumeSnapshot:
773775
args = append(args, fmt.Sprintf("--mode=%s", v1alpha1.RestoreModeVolumeSnapshot))
774776
if !v1alpha1.IsRestoreVolumeComplete(restore) {

tests/e2e/br/br.go

-1
Original file line numberDiff line numberDiff line change
@@ -1127,7 +1127,6 @@ var _ = ginkgo.Describe("Backup and Restore", func() {
11271127
err = createRestoreAndWaitForComplete(f, restoreName, backupClusterName, typ, logBackupName, func(restore *v1alpha1.Restore) {
11281128
restore.Spec.Mode = v1alpha1.RestoreModePiTR
11291129
restore.Spec.PitrFullBackupStorageProvider.S3 = fullBackup.Spec.S3
1130-
restore.Spec.PitrRestoredTs = currentTS
11311130
})
11321131
framework.ExpectNoError(err)
11331132

0 commit comments

Comments
 (0)