fix(stream): disable the deploy msg when restart taosd.

aae27588 · Haojun Liao · 18479d81 · aae27588
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/dnode/vnode/src/vnd/vnodeSvr.c source/dnode/vnode/src/vnd/vnodeSvr.c +1 -1

未找到文件。
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -400,7 +400,7 @@ int32_t vnodeProcessWriteMsg(SVnode *pVnode, SRpcMsg *pMsg, int64_t version, SRp
      }
      break;
    case TDMT_STREAM_TASK_DEPLOY: {
-      if (tqProcessTaskDeployReq(pVnode->pTq, version, pReq, len) < 0) {
+      if (pVnode->restored && tqProcessTaskDeployReq(pVnode->pTq, version, pReq, len) < 0) {
        goto _err;
      }
    } break;