diff --git a/go/pkg/log/repository/log.go b/go/pkg/log/repository/log.go index 216c84c4bb1..cbe0704004a 100644 --- a/go/pkg/log/repository/log.go +++ b/go/pkg/log/repository/log.go @@ -131,8 +131,6 @@ func (r *LogRepository) GetAllCollectionInfoToCompact(ctx context.Context, minCo } if err != nil { trace_log.Error("Error in getting collections to compact from record_log table", zap.Error(err)) - } else { - trace_log.Info("Got collections to compact from record_log table", zap.Int("collectionCount", len(collectionToCompact))) } return } @@ -195,7 +193,6 @@ func (r *LogRepository) GarbageCollection(ctx context.Context) error { } } if len(collectionsToGC) > 0 { - trace_log.Info("Collections to be garbage collected", zap.Strings("collections", collectionsToGC)) var tx pgx.Tx tx, err = r.conn.BeginTx(ctx, pgx.TxOptions{}) if err != nil { diff --git a/go/pkg/sysdb/grpc/collection_service.go b/go/pkg/sysdb/grpc/collection_service.go index aef4b0692e9..89d92a6283f 100644 --- a/go/pkg/sysdb/grpc/collection_service.go +++ b/go/pkg/sysdb/grpc/collection_service.go @@ -144,7 +144,6 @@ func (s *Server) GetCollections(ctx context.Context, req *coordinatorpb.GetColle collectionpb := convertCollectionToProto(collection) res.Collections = append(res.Collections, collectionpb) } - log.Info("GetCollections succeeded", zap.Any("response", res.Collections), zap.Stringp("collection_id", collectionID), zap.Stringp("collection_name", collectionName)) return res, nil } @@ -248,7 +247,6 @@ func (s *Server) UpdateCollection(ctx context.Context, req *coordinatorpb.Update return res, grpcutils.BuildInternalGrpcError(err.Error()) } - log.Info("UpdateCollection succeeded", zap.String("collection_id", collectionID)) return res, nil } @@ -298,6 +296,5 @@ func (s *Server) FlushCollectionCompaction(ctx context.Context, req *coordinator CollectionVersion: flushCollectionInfo.CollectionVersion, LastCompactionTime: flushCollectionInfo.TenantLastCompactionTime, } - log.Info("FlushCollectionCompaction succeeded", zap.String("collection_id", req.CollectionId), zap.Int32("collection_version", req.CollectionVersion), zap.Int64("log_position", req.LogPosition)) return res, nil } diff --git a/go/pkg/sysdb/grpc/segment_service.go b/go/pkg/sysdb/grpc/segment_service.go index 5c892bbe27a..a53481c5551 100644 --- a/go/pkg/sysdb/grpc/segment_service.go +++ b/go/pkg/sysdb/grpc/segment_service.go @@ -72,7 +72,6 @@ func (s *Server) GetSegments(ctx context.Context, req *coordinatorpb.GetSegments segmentpbList = append(segmentpbList, segmentpb) } res.Segments = segmentpbList - log.Info("GetSegments success", zap.String("request", req.String()), zap.String("response", res.String())) return res, nil } @@ -131,6 +130,5 @@ func (s *Server) UpdateSegment(ctx context.Context, req *coordinatorpb.UpdateSeg log.Error("UpdateSegment failed", zap.Error(err), zap.String("request", req.String())) return res, grpcutils.BuildInternalGrpcError(err.Error()) } - log.Info("UpdateSegment success", zap.String("request", req.String())) return res, nil } diff --git a/go/pkg/sysdb/grpc/tenant_database_service.go b/go/pkg/sysdb/grpc/tenant_database_service.go index 95f65d919c6..7f373204dbd 100644 --- a/go/pkg/sysdb/grpc/tenant_database_service.go +++ b/go/pkg/sysdb/grpc/tenant_database_service.go @@ -52,7 +52,6 @@ func (s *Server) GetDatabase(ctx context.Context, req *coordinatorpb.GetDatabase Name: database.Name, Tenant: database.Tenant, } - log.Info("GetDatabase success", zap.String("request", req.String())) return res, nil } @@ -89,7 +88,6 @@ func (s *Server) GetTenant(ctx context.Context, req *coordinatorpb.GetTenantRequ res.Tenant = &coordinatorpb.Tenant{ Name: tenant.Name, } - log.Info("GetTenant success", zap.String("request", req.String())) return res, nil } @@ -117,6 +115,5 @@ func (s *Server) GetLastCompactionTimeForTenant(ctx context.Context, req *coordi LastCompactionTime: tenant.LastCompactionTime, }) } - log.Info("GetLastCompactionTimeForTenant success", zap.String("request", req.String())) return res, nil } diff --git a/go/pkg/sysdb/metastore/db/dao/segment.go b/go/pkg/sysdb/metastore/db/dao/segment.go index 8fb2eb87755..3bcf5bf2a01 100644 --- a/go/pkg/sysdb/metastore/db/dao/segment.go +++ b/go/pkg/sysdb/metastore/db/dao/segment.go @@ -182,7 +182,6 @@ func (s *segmentDb) GetSegments(id types.UniqueID, segmentType *string, scope *s metadata = append(metadata, segmentMetadata) currentSegment.SegmentMetadata = metadata } - log.Info("get segments success", zap.Any("segments", segments)) return segments, nil } @@ -212,7 +211,6 @@ func (s *segmentDb) Update(in *dbmodel.UpdateSegment) error { } func (s *segmentDb) RegisterFilePaths(flushSegmentCompactions []*model.FlushSegmentCompaction) error { - log.Info("register file paths", zap.Any("flushSegmentCompactions", flushSegmentCompactions)) for _, flushSegmentCompaction := range flushSegmentCompactions { filePaths, err := json.Marshal(flushSegmentCompaction.FilePaths) if err != nil { diff --git a/go/pkg/sysdb/metastore/db/dao/tenant.go b/go/pkg/sysdb/metastore/db/dao/tenant.go index a4d730ed314..ba97b276dce 100644 --- a/go/pkg/sysdb/metastore/db/dao/tenant.go +++ b/go/pkg/sysdb/metastore/db/dao/tenant.go @@ -68,7 +68,6 @@ func (s *tenantDb) Insert(tenant *dbmodel.Tenant) error { } func (s *tenantDb) UpdateTenantLastCompactionTime(tenantID string, lastCompactionTime int64) error { - log.Info("UpdateTenantLastCompactionTime", zap.String("tenantID", tenantID), zap.Int64("lastCompactionTime", lastCompactionTime)) var tenants []dbmodel.Tenant result := s.db.Model(&tenants). Clauses(clause.Returning{Columns: []clause.Column{{Name: "id"}}}). @@ -86,7 +85,6 @@ func (s *tenantDb) UpdateTenantLastCompactionTime(tenantID string, lastCompactio } func (s *tenantDb) GetTenantsLastCompactionTime(tenantIDs []string) ([]*dbmodel.Tenant, error) { - log.Info("GetTenantsLastCompactionTime", zap.Any("tenantIDs", tenantIDs)) var tenants []*dbmodel.Tenant result := s.db.Select("id", "last_compaction_time").Find(&tenants, "id IN ?", tenantIDs) diff --git a/rust/worker/src/log/log.rs b/rust/worker/src/log/log.rs index 150bafe9d2b..9681a99b7ca 100644 --- a/rust/worker/src/log/log.rs +++ b/rust/worker/src/log/log.rs @@ -229,7 +229,6 @@ impl GrpcLog { match response { Ok(response) => { let collections = response.into_inner().all_collection_info; - println!("Log got collections with new data: {:?}", collections); let mut result = Vec::new(); for collection in collections { let collection_uuid = match Uuid::parse_str(&collection.collection_id) {