diff --git a/api/internal/logic/core/syncclusterloadlogic.go b/api/internal/logic/core/syncclusterloadlogic.go index 5a84e321..034fc176 100644 --- a/api/internal/logic/core/syncclusterloadlogic.go +++ b/api/internal/logic/core/syncclusterloadlogic.go @@ -25,9 +25,11 @@ func NewSyncClusterLoadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *S func (l *SyncClusterLoadLogic) SyncClusterLoad(req *types.SyncClusterLoadReq) error { if nil != req.ClusterLoadRecords { - var param tracker.ClusterLoadRecord - tool.Convert(req, ¶m) - tracker.SyncClusterLoad(param) + for _, record := range req.ClusterLoadRecords { + var param tracker.ClusterLoadRecord + tool.Convert(record, ¶m) + tracker.SyncClusterLoad(param) + } } return nil }