提交 9f168024 编写于 作者: H Haojun Liao

fix(stream): set the initial value.

上级 abfc2455
......@@ -47,7 +47,7 @@ int tqStreamTasksScanWal(STQ* pTq) {
}
taosWUnLockLatch(&pMeta->lock);
tqInfo("vgId:%d scan wal for stream tasks for %d times", vgId, times);
tqDebug("vgId:%d scan wal for stream tasks for %d times", vgId, times);
} else {
ASSERT(pMeta->walScan >= 1);
}
......
......@@ -61,6 +61,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF
goto _err;
}
pMeta->walScan = 0;
pMeta->vgId = vgId;
pMeta->ahandle = ahandle;
pMeta->expandFunc = expandFunc;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册