diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 8e48b8051d..22a9e2ab1a 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -634,6 +634,7 @@ void metaHbToMnode(void* param, void* tmrId) { } if (!readyToSendHb(&pMeta->hbInfo)) { + taosTmrReset(metaHbToMnode, META_HB_CHECK_INTERVAL, pMeta, streamEnv.timer, &pMeta->hbInfo.hbTmr); return; }