fix avg mean

erda-project · Jul 29, 2024 · e61ccb5 · e61ccb5
1 parent 8acba2d
commit e61ccb5
Show file tree

Hide file tree

Showing 6 changed files with 7 additions and 7 deletions.
diff --git a/internal/apps/msp/apm/service/view/card/avg_duration.go b/internal/apps/msp/apm/service/view/card/avg_duration.go
@@ -31,7 +31,7 @@ type AvgDurationCard struct {
 }
 
 func (r *AvgDurationCard) GetCard(ctx context.Context) (*ServiceCard, error) {
-	statement := fmt.Sprintf("SELECT avg(elapsed_sum::field) "+
+	statement := fmt.Sprintf("SELECT avg(elapsed_mean::field) "+
 		"FROM %s "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+

diff --git a/internal/apps/msp/apm/service/view/chart/avg_duration.go b/internal/apps/msp/apm/service/view/chart/avg_duration.go
@@ -36,7 +36,7 @@ type AvgDurationChart struct {
 }
 
 func (avgDuration *AvgDurationChart) GetChart(ctx context.Context) (*pb.ServiceChart, error) {
-	statement := fmt.Sprintf("SELECT avg(elapsed_sum::field) "+
+	statement := fmt.Sprintf("SELECT avg(elapsed_mean::field) "+
 		"FROM %s "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+

diff --git a/internal/apps/msp/apm/service/view/chart/avg_duration_distribution.go b/internal/apps/msp/apm/service/view/chart/avg_duration_distribution.go
@@ -36,7 +36,7 @@ type AvgDurationDistributionChart struct {
 }
 
 func (avgDuration *AvgDurationDistributionChart) GetChart(ctx context.Context) (*pb.ServiceChart, error) {
-	statement := fmt.Sprintf("SELECT avg(elapsed_sum::field), sum(elapsed_count::field) "+
+	statement := fmt.Sprintf("SELECT avg(elapsed_mean::field), sum(elapsed_count::field) "+
 		"FROM %s "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+

diff --git a/internal/apps/msp/apm/service/view/chart/error_duration_distribution.go b/internal/apps/msp/apm/service/view/chart/error_duration_distribution.go
@@ -36,7 +36,7 @@ type ErrorDurationDistributionChart struct {
 }
 
 func (avgDuration *ErrorDurationDistributionChart) GetChart(ctx context.Context) (*pb.ServiceChart, error) {
-	statement := fmt.Sprintf("SELECT avg(elapsed_sum::field), sum(elapsed_count::field) "+
+	statement := fmt.Sprintf("SELECT avg(elapsed_mean::field), sum(elapsed_count::field) "+
 		"FROM %s_error "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+

diff --git a/internal/apps/msp/apm/service/view/chart/slow_duration_distribution.go b/internal/apps/msp/apm/service/view/chart/slow_duration_distribution.go
@@ -36,7 +36,7 @@ type SlowDurationDistributionChart struct {
 }
 
 func (avgDuration *SlowDurationDistributionChart) GetChart(ctx context.Context) (*pb.ServiceChart, error) {
-	statement := fmt.Sprintf("SELECT avg(elapsed_sum::field), sum(elapsed_count::field) "+
+	statement := fmt.Sprintf("SELECT avg(elapsed_mean::field), sum(elapsed_count::field) "+
 		"FROM %s_slow "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+

diff --git a/internal/apps/msp/apm/service/view/table/transaction.go b/internal/apps/msp/apm/service/view/table/transaction.go
@@ -40,7 +40,7 @@ var (
 var TransactionTableSortFieldSqlMap = map[string]string{
 	columnReqCount.Key:    "sum(elapsed_count::field)",
 	columnErrorCount.Key:  "sum(if(eq(error::tag, 'true'),elapsed_count::field,0))",
-	columnAvgDuration.Key: "avg(elapsed_sum::field)",
+	columnAvgDuration.Key: "avg(elapsed_mean::field)",
 }
 
 type TransactionTableRow struct {
@@ -123,7 +123,7 @@ func (t *TransactionTableBuilder) GetTable(ctx context.Context) (*Table, error)
 		"%s,"+
 		"sum(elapsed_count::field),"+
 		"sum(if(eq(error::tag, 'true'),elapsed_count::field,0)),"+
-		"avg(elapsed_sum::field) "+
+		"avg(elapsed_mean::field) "+
 		"FROM %s "+
 		"WHERE (target_terminus_key::tag=$terminus_key OR source_terminus_key::tag=$terminus_key) "+
 		"%s "+