admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-06 17:18:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip e2e]Format log (#13579)

Browse Source 
Signed-off-by: Cai.Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2021-12-17 22:17:03 +08:00 committed by GitHub
parent 461130e933
commit 037b9b0d4e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/indexcoord/index_coord.go
View File

@ -573,12 +573,12 @@ func (i *IndexCoord) GetIndexFilePaths(ctx context.Context, req *indexpb.GetInde
// GetMetrics gets the metrics info of IndexCoord. // GetMetrics gets the metrics info of IndexCoord.
func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error) { func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error) {
log.Debug("IndexCoord.GetMetrics", log.Debug("IndexCoord.GetMetrics",
zap.Int64("node_id", i.session.ServerID), zap.Int64("node id", i.session.ServerID),
zap.String("req", req.Request)) zap.String("req", req.Request))
if !i.isHealthy() { if !i.isHealthy() {
log.Warn("IndexCoord.GetMetrics failed", log.Warn("IndexCoord.GetMetrics failed",
zap.Int64("node_id", i.session.ServerID), zap.Int64("node id", i.session.ServerID),
zap.String("req", req.Request), zap.String("req", req.Request),
zap.Error(errIndexCoordIsUnhealthy(i.session.ServerID))) zap.Error(errIndexCoordIsUnhealthy(i.session.ServerID)))
@ -594,7 +594,7 @@ func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsReq
metricType, err := metricsinfo.ParseMetricType(req.Request) metricType, err := metricsinfo.ParseMetricType(req.Request)
if err != nil { if err != nil {
log.Error("IndexCoord.GetMetrics failed to parse metric type", log.Error("IndexCoord.GetMetrics failed to parse metric type",
zap.Int64("node_id", i.session.ServerID), zap.Int64("node id", i.session.ServerID),
zap.String("req", req.Request), zap.String("req", req.Request),
zap.Error(err)) zap.Error(err))
@ -608,7 +608,7 @@ func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsReq
} }
log.Debug("IndexCoord.GetMetrics", log.Debug("IndexCoord.GetMetrics",
zap.String("metric_type", metricType)) zap.String("metric type", metricType))
if metricType == metricsinfo.SystemInfoMetrics { if metricType == metricsinfo.SystemInfoMetrics {
ret, err := i.metricsCacheManager.GetSystemInfoMetrics() ret, err := i.metricsCacheManager.GetSystemInfoMetrics()
@ -621,10 +621,10 @@ func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsReq
metrics, err := getSystemInfoMetrics(ctx, req, i) metrics, err := getSystemInfoMetrics(ctx, req, i)
log.Debug("IndexCoord.GetMetrics", log.Debug("IndexCoord.GetMetrics",
zap.Int64("node_id", i.session.ServerID), zap.Int64("node id", i.session.ServerID),
zap.String("req", req.Request), zap.String("req", req.Request),
zap.String("metric_type", metricType), zap.String("metric type", metricType),
zap.Any("metrics", metrics), // TODO(dragondriver): necessary? may be very large zap.String("metrics", metrics.Response), // TODO(dragondriver): necessary? may be very large
zap.Error(err)) zap.Error(err))
i.metricsCacheManager.UpdateSystemInfoMetrics(metrics) i.metricsCacheManager.UpdateSystemInfoMetrics(metrics)
@ -633,9 +633,9 @@ func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsReq
} }
log.Debug("IndexCoord.GetMetrics failed, request metric type is not implemented yet", log.Debug("IndexCoord.GetMetrics failed, request metric type is not implemented yet",
zap.Int64("node_id", i.session.ServerID), zap.Int64("node id", i.session.ServerID),
zap.String("req", req.Request), zap.String("req", req.Request),
zap.String("metric_type", metricType)) zap.String("metric type", metricType))
return &milvuspb.GetMetricsResponse{ return &milvuspb.GetMetricsResponse{
Status: &commonpb.Status{ Status: &commonpb.Status{