[Bug] fix issue #439

in some cases, err.Error() will be called when err is nil, fix it;

Author: ztonny

pkg/common/utils/mysql/mysql.go

@@ -232,8 +232,7 @@ func (db *DB) GetBackendsByComputeGroupId(cgid string) ([]*Backend, error) {
 			return nil, err
 		}
 		if _, ok := m[COMPUTE_GROUP_ID]; !ok {
-			klog.Errorf("GetBackendsByComputeGroupId backends tag get compute_group_name failed, tag: %s, err: %s\n", be.Tag, err.Error())
-			return nil, err
+			return nil, fmt.Errorf("GetBackendsByComputeGroupId backends tag get compute_group_name failed, tag: %s, err: no compute_group_id field found", be.Tag)
 		}
 
 		computegroupId := fmt.Sprintf("%s", m[COMPUTE_GROUP_ID])

pkg/common/utils/resource/configmap_test.go

@@ -110,7 +110,7 @@ func Test_ResolveConfigMpas(t *testing.T) {
 
 	m, err := ResolveConfigMaps(tests, dorisv1.Component_FE)
 	if err != nil || len(m) == 0 {
-		t.Errorf("resolve configmaps faild, len=%d, err=%s", len(m), err.Error())
+		t.Errorf("resolve configmaps faild, len=%d, err=%#v", len(m), err)
 	}
 }
 

pkg/controller/sub_controller/disaggregated_cluster/computegroups/controller.go

@@ -524,7 +524,7 @@ func (dcgs *DisaggregatedComputeGroupsController) ClearStatefulsetUnusedPVCs(ctx
 		var perr error
 		index, perr = strconv.ParseInt(sl[1], 10, 32)
 		if perr != nil {
-			klog.Errorf("DisaggregatedComputeGroupsController ClearStatefulsetUnusedPVCs namespace %s name %s index parse failed, err=%s", ddc.Namespace, pvcName, err.Error())
+			klog.Errorf("DisaggregatedComputeGroupsController ClearStatefulsetUnusedPVCs namespace %s name %s index parse failed, err=%s", ddc.Namespace, pvcName, perr.Error())
 			continue
 		}
 		if int32(index) >= replicas {
@@ -639,8 +639,7 @@ func(dcgs *DisaggregatedComputeGroupsController) recordComputeGroupIds(ddc *dv1.
 			return err
 		}
 		if _, ok := tags[mysql.COMPUTE_GROUP_ID]; !ok {
-			klog.Errorf("DisaggregatedComputeGroupsController recordComputeGroupIds backend tag get compute_group_name failed, tag: %s, err: %s", backend.Tag, err.Error())
-			return err
+			return fmt.Errorf("DisaggregatedComputeGroupsController recordComputeGroupIds backend tag get compute_group_name failed, tag: %s, err: no compute_group_id field found ", backend.Tag)
 		}
 
 		podName := strings.Split(backend.Host, ".")[0]

pkg/controller/sub_controller/sub_controller.go

@@ -290,7 +290,7 @@ func (d *SubDefaultController) CheckSharedPVC(ctx context.Context, dcr *dorisv1.
 	for _, claim := range dcr.Spec.SharedPersistentVolumeClaims {
 		pvc, err := k8s.GetPVC(ctx, d.K8sclient, claim.PersistentVolumeClaimName, dcr.Namespace)
 		if err != nil || pvc == nil {
-			errMessage := fmt.Sprintf("(PersistentVolumeClaim get failed name: %s, namespace: %s, err: %s), ", claim.PersistentVolumeClaimName, dcr.Namespace, err.Error())
+			errMessage := fmt.Sprintf("(PersistentVolumeClaim get failed name: %s, namespace: %s, err: %#v), ", claim.PersistentVolumeClaimName, dcr.Namespace, err)
 			klog.Errorf(errMessage)
 			d.K8srecorder.Event(dcr, string(EventWarning), string(CheckSharePVC), errMessage)
 			return
@@ -555,7 +555,7 @@ func (d *SubDefaultController) listAndDeletePersistentVolumeClaim(ctx context.Co
 
 	dorisPersistentVolumes, err := d.GetFinalPersistentVolumes(ctx, dcr, componentType)
 	if err != nil {
-		d.K8srecorder.Event(dcr, string(EventWarning), PVCExplainFailed, fmt.Sprintf("listAndDeletePersistentVolumeClaim %s GetFinalPersistentVolumes failed：%s", componentType, err.Error()))
+		d.K8srecorder.Event(dcr, string(EventWarning), PVCExplainFailed, fmt.Sprintf("listAndDeletePersistentVolumeClaim %s GetFinalPersistentVolumes failed: %s", componentType, err.Error()))
 		return err
 	}