fix taosd crash issue

a1c69e5a · dapan1121 · 9a922281 · a1c69e5a
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

src/cq/src/cqMain.c src/cq/src/cqMain.c +3 -1

未找到文件。
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -326,8 +326,10 @@ void *cqCreate(void *handle, uint64_t uid, int32_t sid, const char* dstTable, ch

  pObj->rid = taosAddRef(cqObjRef, pObj);

-  if(start) {
+  if(start && pContext->master) {
    cqCreateStream(pContext, pObj);
+  } else {
+    pObj->pContext = pContext;
  }

  rid = pObj->rid;