diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go
index 9dfb6a39b4..c4f690c3bc 100644
--- a/internal/datacoord/services.go
+++ b/internal/datacoord/services.go
@@ -138,7 +138,7 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
 			}
 		}
 		return nil
-	})
+	}, retry.Attempts(20)) // about 60s
 	if err != nil {
 		resp.Status = merr.Status(err)
 		return resp, nil
diff --git a/internal/datanode/services.go b/internal/datanode/services.go
index c7d01774fd..c4fc877d57 100644
--- a/internal/datanode/services.go
+++ b/internal/datanode/services.go
@@ -523,7 +523,7 @@ func (node *DataNode) Import(ctx context.Context, req *datapb.ImportTaskRequest)
 func (node *DataNode) FlushChannels(ctx context.Context, req *datapb.FlushChannelsRequest) (*commonpb.Status, error) {
 	log := log.Ctx(ctx).With(zap.Int64("nodeId", paramtable.GetNodeID()),
 		zap.Time("flushTs", tsoutil.PhysicalTime(req.GetFlushTs())),
-		zap.Int("len(channels)", len(req.GetChannels())))
+		zap.Strings("channels", req.GetChannels()))
 
 	log.Info("DataNode receives FlushChannels request")