diff --git a/manager/client/grampus/grampus.go b/manager/client/grampus/grampus.go index 3d78bfd140..92dbfe3689 100644 --- a/manager/client/grampus/grampus.go +++ b/manager/client/grampus/grampus.go @@ -33,6 +33,7 @@ const ( errorIllegalToken = 1005 errorCannotStopCreatingJob = 5008 + MAX_MATRICS_SIZE = 1000 ) type GetTokenParams struct { @@ -370,6 +371,11 @@ func GetGrampusMetrics(jobID string, startTime int64, endTime int64, nodeId ...i size := int64(math.Ceil(float64(endTime-startTime)/float64(step))) + 1 + if size > MAX_MATRICS_SIZE { + step = int64(math.Ceil(float64(size*step) / float64(MAX_MATRICS_SIZE))) + size = MAX_MATRICS_SIZE + } + url = url + "?startTime=" + strconv.FormatInt(startTime, 10) + "&step=" + strconv.FormatInt(step, 10) + "&size=" + strconv.FormatInt(size, 10) } res, err := client.R().