Merge pull request #19675 from taosdata/fix/task_db

fix: task db

Merge pull request #19675 from taosdata/fix/task_db
fix: task db
69779755 · Haojun Liao · GitHub · 96155040 · 0c6f6d3a · 69779755
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

source/libs/stream/src/streamMeta.c source/libs/stream/src/streamMeta.c +1 -0

未找到文件。
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -207,6 +207,7 @@ void streamMetaRemoveTask(SStreamMeta* pMeta, int32_t taskId) {
  if (ppTask) {
    SStreamTask* pTask = *ppTask;
    taosHashRemove(pMeta->pTasks, &taskId, sizeof(int32_t));
+    tdbTbDelete(pMeta->pTaskDb, &taskId, sizeof(int32_t), pMeta->txn);
    /*if (pTask->timer) {
     * taosTmrStop(pTask->timer);*/
    /*pTask->timer = NULL;*/