diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c index 9b4634500c2d1b74b9e56dd24f7eb0bef33ca084..7bf9fb5f04ce17e32f0ac8d5f1eac5c8d49fdbaa 100644 --- a/source/dnode/vnode/src/vnd/vnodeSvr.c +++ b/source/dnode/vnode/src/vnd/vnodeSvr.c @@ -900,6 +900,11 @@ static int32_t vnodeProcessSubmitReq(SVnode *pVnode, int64_t version, void *pReq // create table if (pSubmitTbData->pCreateTbReq) { + if (metaCreateTable(pVnode->pMeta, version, pSubmitTbData->pCreateTbReq, NULL /* todo */) < 0) { + // TODO + } else { + // TODO + } } // insert data