mirror: retry publish if tarball is not valid

cmd/mirror.go

@@ -465,8 +465,9 @@ func newMirrorPublishCmd() *cobra.Command {
 					goos, goarch, flagSet,
 				)
 				if err != nil {
-					// retry if the error is manifest too old
-					if err == repository.ErrManifestTooOld {
+					// retry if the error is manifest too old or validation failed
+					if err == repository.ErrManifestTooOld ||
+						strings.Contains(err.Error(), "INVALID TARBALL") {
 						fmt.Printf("server returned an error: %s, retry...\n", err)
 						if _, ferr := tarfile.Seek(0, 0); ferr != nil { // reset the reader
 							return ferr

pkg/cluster/operation/upgrade.go

@@ -234,7 +234,7 @@ func increaseScheduleLimit(ctx context.Context, pc *api.PDClient) (
 			newLimit = regionScheduleLimitThreshold
 		}
 		if err := pc.SetReplicationConfig("region-schedule-limit", newLimit); err != nil {
-			// try to revert leader scheduler limit by our best effort, does not make sence
+			// try to revert leader scheduler limit by our best effort, does not make sense
 			// to handle this error again
 			_ = pc.SetReplicationConfig("leader-schedule-limit", currLeaderScheduleLimit)
 			return currLeaderScheduleLimit, currRegionScheduleLimit, err

server/handler/component.go

@@ -102,6 +102,7 @@ func (h *componentSigner) sign(r *http.Request, m *v1manifest.RawManifest) (sr *
 	case model.ErrorWrongSignature:
 		return nil, ErrorForbiden
 	case model.ErrorWrongChecksum, model.ErrorWrongFileName:
+		log.Errorf("Publish component: %s", err.Error())
 		return nil, ErrorInvalidTarball
 	case nil:
 		return nil, nil