From ed942e8f1cc0b28538545140aa129e4932d03139 Mon Sep 17 00:00:00 2001 From: slguan Date: Thu, 19 Dec 2019 17:39:56 +0800 Subject: [PATCH] #952 [TBASE-1356] --- src/client/src/tscServer.c | 3 +++ src/system/detail/src/vnodeShell.c | 3 +++ 2 files changed, 6 insertions(+) diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 1b93096b45..64c0be9283 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -469,6 +469,9 @@ void *tscProcessMsgFromServer(char *msg, void *ahandle, void *thandle) { if (pCmd->command > TSDB_SQL_MGMT) { tscProcessMgmtRedirect(pSql, pMsg->content + 1); + } else if (pCmd->command == TSDB_SQL_INSERT){ + pSql->index++; + pSql->maxRetry = TSDB_VNODES_SUPPORT * 2; } else { pSql->index++; } diff --git a/src/system/detail/src/vnodeShell.c b/src/system/detail/src/vnodeShell.c index 66bede89b7..99535c9aa4 100644 --- a/src/system/detail/src/vnodeShell.c +++ b/src/system/detail/src/vnodeShell.c @@ -118,6 +118,9 @@ void *vnodeProcessMsgFromShell(char *msg, void *ahandle, void *thandle) { } else if (pMsg->msgType == TSDB_MSG_TYPE_SUBMIT) { if (vnodeList[vnode].vnodeStatus == TSDB_VN_STATUS_MASTER) { vnodeProcessShellSubmitRequest((char *) pMsg->content, pMsg->msgLen - sizeof(SIntMsg), pObj); + } else if (vnodeList[vnode].vnodeStatus == TSDB_VN_STATUS_SLAVE) { + taosSendSimpleRsp(thandle, pMsg->msgType + 1, TSDB_CODE_REDIRECT); + dTrace("vid:%d sid:%d, shell submit msg is redirect since in status:%s", vnode, sid, taosGetVnodeStatusStr(vnodeList[vnode].vnodeStatus)); } else { taosSendSimpleRsp(thandle, pMsg->msgType + 1, TSDB_CODE_NOT_READY); dTrace("vid:%d sid:%d, shell submit msg is ignored since in status:%s", vnode, sid, taosGetVnodeStatusStr(vnodeList[vnode].vnodeStatus)); -- GitLab