From a9d288f2d20e0b82756d7bcb8783b09b858ce5b7 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 12 Dec 2024 09:23:34 +0800 Subject: [PATCH] fix(stream): update the function signature. --- source/libs/stream/src/streamHb.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamHb.c b/source/libs/stream/src/streamHb.c index 16466bee7d..35d520cae8 100644 --- a/source/libs/stream/src/streamHb.c +++ b/source/libs/stream/src/streamHb.c @@ -152,7 +152,7 @@ static int32_t streamTaskGetMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) { return TSDB_CODE_FAILED; } -static int32_t streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) { +static void streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) { int32_t numOfTasks = streamMetaGetNumOfTasks(pMeta); for (int32_t i = 0; i < numOfTasks; ++i) { @@ -185,7 +185,7 @@ static int32_t streamTaskUpdateMndEpset(SStreamMeta* pMeta, SEpSet* pEpSet) { streamMetaReleaseTask(pMeta, pTask); } - return TSDB_CODE_SUCCESS; + stDebug("vgId:%d update mnd epset for %d tasks completed", pMeta->vgId, numOfTasks); } // NOTE: this task should be executed within the SStreamMeta lock region.