From 6f636356869392c29cfbf237b80de52bdbd35fbf Mon Sep 17 00:00:00 2001 From: congqixia Date: Tue, 21 Dec 2021 15:36:05 +0800 Subject: [PATCH] [skip e2e] Add comment for Compaction method in session_manager.go (#13858) Signed-off-by: Congqi Xia --- internal/datacoord/session_manager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/datacoord/session_manager.go b/internal/datacoord/session_manager.go index ed4a0256e7..695e88fc39 100644 --- a/internal/datacoord/session_manager.go +++ b/internal/datacoord/session_manager.go @@ -125,6 +125,7 @@ func (c *SessionManager) execFlush(ctx context.Context, nodeID int64, req *datap log.Debug("success to flush", zap.Int64("node", nodeID), zap.Any("segments", req)) } +// Compaction is a grpc interface. It will send request to DataNode with provided `nodeID` asynchronously. func (c *SessionManager) Compaction(nodeID int64, plan *datapb.CompactionPlan) { go c.execCompaction(nodeID, plan) }