From 251bdf51c18d50f4a72434d5693019293c44f792 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 29 Aug 2024 16:02:33 +0800 Subject: [PATCH] fix(stream): fix syntax error. --- source/libs/stream/src/streamStartTask.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamStartTask.c b/source/libs/stream/src/streamStartTask.c index d5d6163009..c2e8a523e5 100644 --- a/source/libs/stream/src/streamStartTask.c +++ b/source/libs/stream/src/streamStartTask.c @@ -455,7 +455,7 @@ int32_t streamTaskCheckIfReqConsenChkptId(SStreamTask* pTask, int64_t ts) { vgId, pConChkptInfo->statusTs); return 1; } else { - int64_t el = (ts - pConChkptInfo->statusTs) / 1000; + int32_t el = (ts - pConChkptInfo->statusTs) / 1000; if ((pConChkptInfo->status == TASK_CONSEN_CHKPT_SEND) && el > 60) { pConChkptInfo->statusTs = ts;