refactor: do some internal refactor.

This commit is contained in:
Haojun Liao 2024-07-05 18:06:00 +08:00
parent 8e6bb176c2
commit 6a1555e893
1 changed files with 1 additions and 0 deletions

View File

@ -1138,6 +1138,7 @@ static int32_t mndCheckTaskAndNodeStatus(SMnode *pMnode) {
mDebug("s-task:0x%" PRIx64 "-0x%x (nodeId:%d) status:%s, checkpoint not issued", pEntry->id.streamId, mDebug("s-task:0x%" PRIx64 "-0x%x (nodeId:%d) status:%s, checkpoint not issued", pEntry->id.streamId,
(int32_t)pEntry->id.taskId, pEntry->nodeId, streamTaskGetStatusStr(pEntry->status)); (int32_t)pEntry->id.taskId, pEntry->nodeId, streamTaskGetStatusStr(pEntry->status));
ready = false; ready = false;
break;
} }
if (pEntry->hTaskId != 0) { if (pEntry->hTaskId != 0) {