diff --git a/pkg/cloudmon/providerdriver/base.go b/pkg/cloudmon/providerdriver/base.go
index f9ec678edc..c2218f30a7 100644
--- a/pkg/cloudmon/providerdriver/base.go
+++ b/pkg/cloudmon/providerdriver/base.go
@@ -896,7 +896,7 @@ func (self *SCollectByMetricTypeDriver) CollectRedisMetrics(ctx context.Context,
 				}
 				for _, v := range value.Values {
 					metric := influxdb.SMetricData{
-						Name:      value.MetricType.Key(),
+						Name:      value.MetricType.Name(),
 						Timestamp: v.Timestamp,
 						Tags:      []influxdb.SKeyValue{},
 						Metrics: []influxdb.SKeyValue{
@@ -978,7 +978,7 @@ func (self *SCollectByMetricTypeDriver) CollectBucketMetrics(ctx context.Context
 				}
 				for _, v := range value.Values {
 					metric := influxdb.SMetricData{
-						Name:      value.MetricType.Key(),
+						Name:      value.MetricType.Name(),
 						Timestamp: v.Timestamp,
 						Tags:      []influxdb.SKeyValue{},
 						Metrics: []influxdb.SKeyValue{
diff --git a/pkg/cloudmon/resources/resources.go b/pkg/cloudmon/resources/resources.go
index de4277b154..cd4ce54a37 100644
--- a/pkg/cloudmon/resources/resources.go
+++ b/pkg/cloudmon/resources/resources.go
@@ -660,7 +660,7 @@ func (self *SResources) CollectMetrics(ctx context.Context, userCred mcclient.To
 
 			resources = self.KubeClusters.getResources(manager.Id)
 			clusters := map[string]api.KubeClusterDetails{}
-			jsonutils.Update(&buckets, resources)
+			jsonutils.Update(&clusters, resources)
 			err = driver.CollectK8sMetrics(ctx, manager, provider, clusters, startTime, endTime)
 			if err != nil && errors.Cause(err) != cloudprovider.ErrNotImplemented && errors.Cause(err) != cloudprovider.ErrNotSupported {
 				log.Errorf("CollectK8sMetrics for %s(%s) error: %v", manager.Name, manager.Provider, err)