diff --git a/internal/datacoord/session_manager.go b/internal/datacoord/session_manager.go
index 2c6942dab5..03207fc6c0 100644
--- a/internal/datacoord/session_manager.go
+++ b/internal/datacoord/session_manager.go
@@ -33,6 +33,7 @@ import (
 	"github.com/milvus-io/milvus/pkg/util/commonpbutil"
 	"github.com/milvus-io/milvus/pkg/util/paramtable"
 	"github.com/milvus-io/milvus/pkg/util/retry"
+	"github.com/milvus-io/milvus/pkg/util/tsoutil"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"
 )
 
@@ -302,13 +303,16 @@ func (c *SessionManager) GetCompactionState() map[int64]*datapb.CompactionStateR
 }
 
 func (c *SessionManager) FlushChannels(ctx context.Context, nodeID int64, req *datapb.FlushChannelsRequest) error {
-	log := log.Ctx(ctx).With(zap.Int64("nodeID", nodeID))
+	log := log.Ctx(ctx).With(zap.Int64("nodeID", nodeID),
+		zap.Time("flushTs", tsoutil.PhysicalTime(req.GetFlushTs())),
+		zap.Strings("channels", req.GetChannels()))
 	cli, err := c.getClient(ctx, nodeID)
 	if err != nil {
 		log.Warn("failed to get client", zap.Error(err))
 		return err
 	}
 
+	log.Info("SessionManager.FlushChannels start")
 	resp, err := cli.FlushChannels(ctx, req)
 	err = VerifyResponse(resp, err)
 	if err != nil {