diff --git a/internal/distributed/proxy/httpserver/handler_v2.go b/internal/distributed/proxy/httpserver/handler_v2.go index 0139d441d2..a2b24b63fb 100644 --- a/internal/distributed/proxy/httpserver/handler_v2.go +++ b/internal/distributed/proxy/httpserver/handler_v2.go @@ -1560,6 +1560,13 @@ func (h *HandlersV2) createCollection(ctx context.Context, c *gin.Context, anyRe Value: fmt.Sprintf("%v", httpReq.Params["partitionKeyIsolation"]), }) } + if _, ok := httpReq.Params[common.MmapEnabledKey]; ok { + req.Properties = append(req.Properties, &commonpb.KeyValuePair{ + Key: common.MmapEnabledKey, + Value: fmt.Sprintf("%v", httpReq.Params[common.MmapEnabledKey]), + }) + } + resp, err := wrapperProxyWithLimit(ctx, c, req, h.checkAuth, false, "/milvus.proto.milvus.MilvusService/CreateCollection", true, h.proxy, func(reqCtx context.Context, req any) (interface{}, error) { return h.proxy.CreateCollection(reqCtx, req.(*milvuspb.CreateCollectionRequest)) })