fix(stream): adjust critical section.

This commit is contained in:
Haojun Liao 2023-11-10 10:26:45 +08:00
parent ecf6c1c09d
commit 233777b6ac
1 changed files with 3 additions and 1 deletions

View File

@ -1934,10 +1934,12 @@ int32_t tqProcessTaskUpdateReq(STQ* pTq, SRpcMsg* pMsg) {
} else {
tqDebug("vgId:%d all %d task(s) nodeEp updated and closed", vgId, numOfTasks);
streamMetaWUnLock(pMeta);
#if 1
tqStartStreamTaskAsync(pTq, true);
streamMetaWUnLock(pMeta);
#else
streamMetaWUnLock(pMeta);
// For debug purpose.
// the following procedure consume many CPU resource, result in the re-election of leader
// with high probability. So we employ it as a test case for the stream processing framework, with