Skip to content

Commit 8c4d8b3

Browse files
committed
fix: convert shard cluster failed (#589)
(cherry picked from commit 0d27765)
1 parent 55f0283 commit 8c4d8b3

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

Diff for: pkg/cmd/cluster/covert_to_1.0.go

+10-2
Original file line numberDiff line numberDiff line change
@@ -516,7 +516,7 @@ func (o *ConvertToV1Options) normalizeConfigMaps() error {
516516
return err
517517
}
518518
if _, err = o.Dynamic.Resource(types.ConfigmapGVR()).Namespace(o.Namespace).Patch(context.TODO(), cm.GetName(), apitypes.MergePatchType, newData, metav1.PatchOptions{}); err != nil {
519-
return err
519+
return client.IgnoreNotFound(err)
520520
}
521521
return nil
522522
}
@@ -526,7 +526,7 @@ func (o *ConvertToV1Options) normalizeConfigMaps() error {
526526
if _, ok := labels[constant.CMConfigurationSpecProviderLabelKey]; !ok {
527527
// add file-template label for scripts
528528
if _, isScripts := labels[constant.CMTemplateNameLabelKey]; isScripts {
529-
if err = o.Dynamic.Resource(types.ConfigmapGVR()).Namespace(cm.GetNamespace()).Delete(context.TODO(), cm.GetName(), metav1.DeleteOptions{}); err != nil {
529+
if err = o.Dynamic.Resource(types.ConfigmapGVR()).Namespace(cm.GetNamespace()).Delete(context.TODO(), cm.GetName(), metav1.DeleteOptions{}); client.IgnoreNotFound(err) != nil {
530530
return err
531531
}
532532
}
@@ -627,13 +627,21 @@ func (o *ConvertToV1Options) Convert09ComponentDef(cluster *kbappsv1.Cluster,
627627
return err
628628
}
629629
cluster.Spec.ComponentSpecs[i].ComponentDef = compDef
630+
// reset service account name
631+
if cluster.Spec.ComponentSpecs[i].ServiceAccountName == fmt.Sprintf("kb-%s", cluster.Name) {
632+
cluster.Spec.ComponentSpecs[i].ServiceAccountName = ""
633+
}
630634
}
631635
for i := range clusterV1alpha1Spec.ShardingSpecs {
632636
compDef, err := convertCompDef(clusterV1alpha1Spec.ShardingSpecs[i].Template.ComponentDef)
633637
if err != nil {
634638
return err
635639
}
636640
cluster.Spec.Shardings[i].Template.ComponentDef = compDef
641+
// reset service account name
642+
if cluster.Spec.Shardings[i].Template.ServiceAccountName == fmt.Sprintf("kb-%s", cluster.Name) {
643+
cluster.Spec.Shardings[i].Template.ServiceAccountName = ""
644+
}
637645
}
638646
delete(cluster.Annotations, kbIncrementConverterAK)
639647
return nil

0 commit comments

Comments
 (0)