diff --git a/cmd/velero-restore-helper/velero-restore-helper.go b/cmd/velero-restore-helper/velero-restore-helper.go index a6039381d..748f1e6c8 100644 --- a/cmd/velero-restore-helper/velero-restore-helper.go +++ b/cmd/velero-restore-helper/velero-restore-helper.go @@ -66,10 +66,10 @@ func done() bool { doneFile := filepath.Join("/restores", child.Name(), ".velero", os.Args[1]) if _, err := os.Stat(doneFile); os.IsNotExist(err) { - fmt.Printf("Not found: %s\n", doneFile) + fmt.Printf("The filesystem restore done file %s is not found yet. Retry later.\n", doneFile) return false } else if err != nil { - fmt.Fprintf(os.Stderr, "ERROR looking for %s: %s\n", doneFile, err) + fmt.Fprintf(os.Stderr, "ERROR looking filesystem restore done file %s: %s\n", doneFile, err) return false } diff --git a/pkg/cmd/cli/schedule/create.go b/pkg/cmd/cli/schedule/create.go index 32f277136..c9304e078 100644 --- a/pkg/cmd/cli/schedule/create.go +++ b/pkg/cmd/cli/schedule/create.go @@ -171,6 +171,12 @@ func (o *CreateOptions) Run(c *cobra.Command, f client.Factory) error { schedule.Spec.Template.ResourcePolicy = &v1.TypedLocalObjectReference{Kind: resourcepolicies.ConfigmapRefType, Name: o.BackupOptions.ResPoliciesConfigmap} } + if o.BackupOptions.ParallelFilesUpload > 0 { + schedule.Spec.Template.UploaderConfig = &api.UploaderConfigForBackup{ + ParallelFilesUpload: o.BackupOptions.ParallelFilesUpload, + } + } + if printed, err := output.PrintWithFormat(c, schedule); printed || err != nil { return err }