fix(stream): adjust critical section.

This commit is contained in:
Haojun Liao 2023-11-10 10:26:45 +08:00
parent 8e5db21c3f
commit 8925c721e5
1 changed files with 3 additions and 1 deletions

View File

@ -1939,10 +1939,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