diff --git a/internal/rootcoord/create_collection_task.go b/internal/rootcoord/create_collection_task.go index 1e6d281b3f..1550f247fd 100644 --- a/internal/rootcoord/create_collection_task.go +++ b/internal/rootcoord/create_collection_task.go @@ -54,7 +54,7 @@ func (t *createCollectionTask) validate() error { shardsNum := int64(t.Req.GetShardsNum()) cfgMaxShardNum := Params.RootCoordCfg.DmlChannelNum - if shardsNum >= cfgMaxShardNum { + if shardsNum > cfgMaxShardNum { return fmt.Errorf("shard num (%d) exceeds max configuration (%d)", shardsNum, cfgMaxShardNum) }