diff --git a/internal/datacoord/channel_store.go b/internal/datacoord/channel_store.go index 3c2e7de832..9d8fa7dbfa 100644 --- a/internal/datacoord/channel_store.go +++ b/internal/datacoord/channel_store.go @@ -192,7 +192,7 @@ func (c *ChannelStore) Update(opSet ChannelOpSet) error { if op.Type == Add { chOp.ChannelWatchInfos = []*datapb.ChannelWatchInfo{op.ChannelWatchInfos[i]} } - channelsOpSet[ch.name] = append(channelsOpSet[ch.name], chOp) + channelsOpSet[ch.Name] = append(channelsOpSet[ch.Name], chOp) } }