diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 209ff4cc73..5cc3310e11 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -210,6 +210,7 @@ void streamMetaClose(SStreamMeta* pMeta) { if (pMeta == NULL) { return; } + // TODO, add ref to resolve race: timer thread cannot stop taosTmrStop(pMeta->hbInfo.hbTmr); streamMetaClear(pMeta);