提交 27db6cfd 编写于 作者: K kailixu

enh: disable udf/stream for mnd on windows

上级 f7a5bef1
...@@ -668,6 +668,12 @@ static int32_t mndProcessCreateDbReq(SRpcMsg *pReq) { ...@@ -668,6 +668,12 @@ static int32_t mndProcessCreateDbReq(SRpcMsg *pReq) {
} }
mInfo("db:%s, start to create, vgroups:%d", createReq.db, createReq.numOfVgroups); mInfo("db:%s, start to create, vgroups:%d", createReq.db, createReq.numOfVgroups);
#ifdef WINDOWS
if (taosArrayGetSize(createReq.pRetensions) > 0) {
code = TSDB_CODE_PAR_INVALID_PLATFORM;
goto _OVER;
}
#endif
if (mndCheckDbPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_DB, NULL) != 0) { if (mndCheckDbPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_DB, NULL) != 0) {
goto _OVER; goto _OVER;
} }
......
...@@ -361,6 +361,10 @@ static int32_t mndProcessCreateFuncReq(SRpcMsg *pReq) { ...@@ -361,6 +361,10 @@ static int32_t mndProcessCreateFuncReq(SRpcMsg *pReq) {
} }
mInfo("func:%s, start to create, size:%d", createReq.name, createReq.codeLen); mInfo("func:%s, start to create, size:%d", createReq.name, createReq.codeLen);
#ifdef WINDOWS
code = TSDB_CODE_PAR_INVALID_PLATFORM;
goto _OVER;
#endif
if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_FUNC) != 0) { if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_FUNC) != 0) {
goto _OVER; goto _OVER;
} }
......
...@@ -655,6 +655,10 @@ _OVER: ...@@ -655,6 +655,10 @@ _OVER:
} }
static int32_t mndCheckCreateSmaReq(SMCreateSmaReq *pCreate) { static int32_t mndCheckCreateSmaReq(SMCreateSmaReq *pCreate) {
#ifdef WINDOWS
terrno = TSDB_CODE_PAR_INVALID_PLATFORM;
return -1;
#endif
terrno = TSDB_CODE_MND_INVALID_SMA_OPTION; terrno = TSDB_CODE_MND_INVALID_SMA_OPTION;
if (pCreate->name[0] == 0) return -1; if (pCreate->name[0] == 0) return -1;
if (pCreate->stb[0] == 0) return -1; if (pCreate->stb[0] == 0) return -1;
......
...@@ -253,6 +253,10 @@ static void mndShowStreamTrigger(char *dst, SStreamObj *pStream) { ...@@ -253,6 +253,10 @@ static void mndShowStreamTrigger(char *dst, SStreamObj *pStream) {
} }
static int32_t mndCheckCreateStreamReq(SCMCreateStreamReq *pCreate) { static int32_t mndCheckCreateStreamReq(SCMCreateStreamReq *pCreate) {
#ifdef WINDOWS
terrno = TSDB_CODE_PAR_INVALID_PLATFORM;
return -1;
#endif
if (pCreate->name[0] == 0 || pCreate->sql == NULL || pCreate->sql[0] == 0 || pCreate->sourceDB[0] == 0 || if (pCreate->name[0] == 0 || pCreate->sql == NULL || pCreate->sql[0] == 0 || pCreate->sourceDB[0] == 0 ||
pCreate->targetStbFullName[0] == 0) { pCreate->targetStbFullName[0] == 0) {
terrno = TSDB_CODE_MND_INVALID_STREAM_OPTION; terrno = TSDB_CODE_MND_INVALID_STREAM_OPTION;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册