From f0f4b988a13ad90e5ba9b90df0cc4ddc950612d3 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 16 Nov 2023 17:00:50 +0800 Subject: [PATCH] fix(stream): fix syntax error. --- source/libs/stream/src/streamDispatch.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamDispatch.c b/source/libs/stream/src/streamDispatch.c index 21fedfc78b..b3e3cb554d 100644 --- a/source/libs/stream/src/streamDispatch.c +++ b/source/libs/stream/src/streamDispatch.c @@ -1050,7 +1050,7 @@ static void dispatchDataInFuture(void* param, void* tmrId) { ETaskStatus status = streamTaskGetStatus(pTask, NULL); if (status == TASK_STATUS__CK) { stDebug("s-task:%s in checkpoint status, wait for 500ms to dispatch data downstream", pTask->id.idStr); - taosTmrReset(doRetryDispatchData, 500, pTask, streamEnv.timer, &pTask->msgInfo.pTimer); + taosTmrReset(dispatchDataInFuture, 500, pTask, streamEnv.timer, &pTask->msgInfo.pTimer); } else { int32_t ref = atomic_sub_fetch_32(&pTask->status.timerActive, 1); stDebug("s-task:%s start to dispatch data, jump out of timer, ref:%d", pTask->id.idStr, ref);