xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

other: comment invalid sleep for test purpose

This commit is contained in:
Haojun Liao 2024-05-29 09:16:37 +08:00
parent 225dfb1a93
commit a9abe78eab
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/stream/src/streamCheckpoint.c
View File

@ -196,9 +196,10 @@ int32_t streamProcessCheckpointTriggerBlock(SStreamTask* pTask, SStreamDataBlock
} }
int32_t ref = atomic_add_fetch_32(&pTask->status.timerActive, 1); int32_t ref = atomic_add_fetch_32(&pTask->status.timerActive, 1);
stDebug("s-task:%s start check-rsp monitor in 10s, ref:%d ", pTask->id.idStr, ref); stDebug("s-task:%s start checkpoint-trigger monitor in 10s, ref:%d ", pTask->id.idStr, ref);
SActiveCheckpointInfo* pActive = pTask->chkInfo.pActiveInfo; SActiveCheckpointInfo* pActive = pTask->chkInfo.pActiveInfo;
if (pActive->pCheckTmr == NULL) { if (pActive->pCheckTmr == NULL) {
streamMetaAcquireOneTask(pTask);
pActive->pCheckTmr = taosTmrStart(checkpointTriggerMonitorFn, 100, pTask, streamTimer); pActive->pCheckTmr = taosTmrStart(checkpointTriggerMonitorFn, 100, pTask, streamTimer);
} else { } else {
taosTmrReset(checkpointTriggerMonitorFn, 100, pTask, streamTimer, &pActive->pCheckTmr); taosTmrReset(checkpointTriggerMonitorFn, 100, pTask, streamTimer, &pActive->pCheckTmr);

2
source/libs/stream/src/streamExec.c
View File

@ -598,7 +598,7 @@ static int32_t doStreamExecTask(SStreamTask* pTask) {
int32_t type = pInput->type; int32_t type = pInput->type;
if (type == STREAM_INPUT__CHECKPOINT_TRIGGER) { if (type == STREAM_INPUT__CHECKPOINT_TRIGGER) {
if (pTask->pMeta->vgId == 2) { if (pTask->pMeta->vgId == 2) {
taosSsleep(20); // taosSsleep(20);
} }
streamProcessCheckpointTriggerBlock(pTask, (SStreamDataBlock*)pInput); streamProcessCheckpointTriggerBlock(pTask, (SStreamDataBlock*)pInput);