fix(stream): disable stream checkpoint when related fill-history task exists.
This commit is contained in:
parent
31317c4895
commit
f13dc1858a
|
@ -1108,6 +1108,15 @@ static int32_t mndCheckNodeStatus(SMnode *pMnode) {
|
||||||
ready = false;
|
ready = false;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (pEntry->hTaskId != 0) {
|
||||||
|
mDebug("s-task:0x%" PRIx64 "-0x%x (nodeId:%d) status:%s related fill-history task:0x%" PRIx64
|
||||||
|
" exists, checkpoint not issued",
|
||||||
|
pEntry->id.streamId, (int32_t)pEntry->id.taskId, pEntry->nodeId, streamTaskGetStatusStr(pEntry->status),
|
||||||
|
pEntry->hTaskId);
|
||||||
|
ready = false;
|
||||||
|
break;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
taosThreadMutexUnlock(&execInfo.lock);
|
taosThreadMutexUnlock(&execInfo.lock);
|
||||||
|
|
Loading…
Reference in New Issue