br: cp bugfix from operator v1 (#6400)

Author: RidRisR

api/br/v1alpha1/restore_types.go

@@ -130,8 +130,8 @@ type RestoreSpec struct {
 	StorageProvider `json:",inline"`
 	// BR is the configs for BR.
 	BR *BRConfig `json:"br,omitempty"`
-
 	// PitrRestoredTs is the pitr restored ts.
+	// +optional
 	PitrRestoredTs string `json:"pitrRestoredTs,omitempty"`
 	// LogRestoreStartTs is the start timestamp which log restore from.
 	// +optional
@@ -184,6 +184,8 @@ type RestoreSpec struct {
 	// TolerateSingleTiKVOutage indicates whether to tolerate a single failure of a store without data loss
 	// +kubebuilder:default=false
 	TolerateSingleTiKVOutage bool `json:"tolerateSingleTiKVOutage,omitempty"`
+	// +kubebuilder:default=0
+	BackoffLimit int32 `json:"backoffLimit,omitempty"`
 }
 
 // RestoreStatus represents the current status of a tidb cluster restore.

manifests/crd/br.pingcap.com_restores.yaml

@@ -2886,6 +2886,10 @@ spec:
                       Otherwise retrieve the storage account from secret
                     type: string
                 type: object
+              backoffLimit:
+                default: 0
+                format: int32
+                type: integer
               backupType:
                 description: Type is the backup type for tidb cluster and only used
                   when Mode = snapshot, such as full, db, table.

pkg/controllers/br/manager/restore/restore_manager.go

@@ -24,7 +24,6 @@ import (
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/tools/record"
-	"k8s.io/utils/ptr"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/log"
 
@@ -228,7 +227,10 @@ func (rm *restoreManager) makeRestoreJob(ctx context.Context, restore *v1alpha1.
 
 	switch restore.Spec.Mode {
 	case v1alpha1.RestoreModePiTR:
-		args = append(args, fmt.Sprintf("--mode=%s", v1alpha1.RestoreModePiTR), fmt.Sprintf("--pitrRestoredTs=%s", restore.Spec.PitrRestoredTs))
+		args = append(args, fmt.Sprintf("--mode=%s", v1alpha1.RestoreModePiTR))
+		if restore.Spec.PitrRestoredTs != "" {
+			args = append(args, fmt.Sprintf("--pitrRestoredTs=%s", restore.Spec.PitrRestoredTs))
+		}
 	default:
 		args = append(args, fmt.Sprintf("--mode=%s", v1alpha1.RestoreModeSnapshot))
 	}
@@ -355,7 +357,7 @@ func (rm *restoreManager) makeRestoreJob(ctx context.Context, restore *v1alpha1.
 			},
 		},
 		Spec: batchv1.JobSpec{
-			BackoffLimit: ptr.To(int32(0)),
+			BackoffLimit: &restore.Spec.BackoffLimit,
 			Template:     *podSpec,
 		},
 	}