diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go
index 2fa9e35560..23c35a02a9 100644
--- a/internal/datacoord/services.go
+++ b/internal/datacoord/services.go
@@ -284,7 +284,9 @@ func (s *Server) GetInsertBinlogPaths(ctx context.Context, req *datapb.GetInsert
 // GetCollectionStatistics returns statistics for collection
 // for now only row count is returned
 func (s *Server) GetCollectionStatistics(ctx context.Context, req *datapb.GetCollectionStatisticsRequest) (*datapb.GetCollectionStatisticsResponse, error) {
-	log := log.Ctx(ctx)
+	log := log.Ctx(ctx).With(
+		zap.Int64("collectionID", req.GetCollectionID()),
+	)
 	log.Info("received request to get collection statistics")
 	resp := &datapb.GetCollectionStatisticsResponse{
 		Status: &commonpb.Status{
@@ -306,7 +308,9 @@ func (s *Server) GetCollectionStatistics(ctx context.Context, req *datapb.GetCol
 // if partID is empty, return statistics for all partitions of the collection
 // for now only row count is returned
 func (s *Server) GetPartitionStatistics(ctx context.Context, req *datapb.GetPartitionStatisticsRequest) (*datapb.GetPartitionStatisticsResponse, error) {
-	log := log.Ctx(ctx)
+	log := log.Ctx(ctx).With(
+		zap.Int64s("partitionIDs", req.GetPartitionIDs()),
+	)
 	resp := &datapb.GetPartitionStatisticsResponse{
 		Status: &commonpb.Status{
 			ErrorCode: commonpb.ErrorCode_UnexpectedError,