diff --git a/internal/rootcoord/dml_channels.go b/internal/rootcoord/dml_channels.go index 980110726129ee3f30dce46e31ae2881ebd164d4..acc9a9c228368c14e60e98c0b6d9450993796e43 100644 --- a/internal/rootcoord/dml_channels.go +++ b/internal/rootcoord/dml_channels.go @@ -172,7 +172,9 @@ func newDmlChannels(ctx context.Context, factory msgstream.Factory, chanNamePref } heap.Init(&d.channelsHeap) - log.Debug("init dml channels", zap.Int64("num", chanNum)) + + log.Info("init dml channels", zap.String("prefix", chanNamePrefix), zap.Int64("num", chanNum)) + metrics.RootCoordNumOfDMLChannel.Add(float64(chanNum)) metrics.RootCoordNumOfMsgStream.Add(float64(chanNum))