work around

Signed-off-by: Lloyd-Pottiger <yan1579196623@gmail.com>

Author: Lloyd-Pottiger

pkg/cluster/manager/patch.go

@@ -147,13 +147,18 @@ func checkPackage(specManager *spec.SpecManager, name string, inst spec.Instance
 	}
 
 	ver := inst.CalculateVersion(metadata.GetBaseMeta().Version)
-	repo, err := clusterutil.NewRepository(nodeOS, arch)
-	if err != nil {
-		return err
-	}
-	entry, err := repo.ComponentBinEntry(inst.ComponentSource(), ver)
-	if err != nil {
-		return err
+	var entry string
+	if inst.ComponentName() == spec.ComponentTiKVWorker {
+		entry = spec.ComponentTiKVWorker
+	} else {
+		repo, err := clusterutil.NewRepository(nodeOS, arch)
+		if err != nil {
+			return err
+		}
+		entry, err = repo.ComponentBinEntry(inst.ComponentSource(), ver)
+		if err != nil {
+			return err
+		}
 	}
 
 	checksum, err := utils.Checksum(packagePath)

pkg/cluster/task/copy_component.go

@@ -19,7 +19,9 @@ import (
 
 	"github.com/pingcap/tiup/pkg/cluster/spec"
 	"github.com/pingcap/tiup/pkg/environment"
+	logprinter "github.com/pingcap/tiup/pkg/logger/printer"
 	"github.com/pingcap/tiup/pkg/repository"
+	"github.com/pingcap/tiup/pkg/utils"
 )
 
 // CopyComponent is used to copy all files related the specific version a component
@@ -51,9 +53,16 @@ func (c *CopyComponent) Execute(ctx context.Context) error {
 
 	// Copy to remote server
 	srcPath := c.srcPath
+	useDefaultSrcPath := srcPath == ""
 	if srcPath == "" {
 		srcPath = spec.PackagePath(c.component, c.version, c.os, c.arch)
 	}
+	if useDefaultSrcPath && c.component == spec.ComponentTiKVWorker && utils.IsNotExist(srcPath) {
+		if logger, ok := ctx.Value(logprinter.ContextKeyLogger).(*logprinter.Logger); ok {
+			logger.Warnf("Skip copying %s:%s because package was not found at %s", c.component, c.version, srcPath)
+		}
+		return nil
+	}
 
 	install := &InstallPackage{
 		srcPath: srcPath,

pkg/cluster/task/download.go

@@ -17,8 +17,11 @@ import (
 	"context"
 	"fmt"
 
+	"github.com/pingcap/errors"
 	operator "github.com/pingcap/tiup/pkg/cluster/operation"
+	"github.com/pingcap/tiup/pkg/cluster/spec"
 	"github.com/pingcap/tiup/pkg/environment"
+	"github.com/pingcap/tiup/pkg/logger/printer"
 	"github.com/pingcap/tiup/pkg/repository"
 )
 
@@ -42,7 +45,7 @@ func NewDownloader(component string, os string, arch string, version string) *Do
 }
 
 // Execute implements the Task interface
-func (d *Downloader) Execute(_ context.Context) error {
+func (d *Downloader) Execute(ctx context.Context) error {
 	// If the version is not specified, the last stable one will be used
 	if d.version == "" {
 		env := environment.GlobalEnv()
@@ -55,7 +58,17 @@ func (d *Downloader) Execute(_ context.Context) error {
 		}
 		d.version = string(ver)
 	}
-	return operator.Download(d.component, d.os, d.arch, d.version)
+	err := operator.Download(d.component, d.os, d.arch, d.version)
+	if err == nil {
+		return nil
+	}
+	if d.component == spec.ComponentTiKVWorker && (errors.Cause(err) == repository.ErrUnknownComponent || errors.Cause(err) == repository.ErrUnknownVersion) {
+		if logger, ok := ctx.Value(logprinter.ContextKeyLogger).(*logprinter.Logger); ok {
+			logger.Warnf("Skip downloading %s:%s (%s/%s): %s", d.component, d.version, d.os, d.arch, err.Error())
+		}
+		return nil
+	}
+	return err
 }
 
 // Rollback implements the Task interface